public void close ( Throwable cause ) { requireNonNull ( cause , "cause" ) ; final DefaultStreamMessage < T > m = new DefaultStreamMessage <> ( ) ; m . close ( cause ) ; delegate ( m ) ; }
Closes the deferred stream without setting a delegate .