public void stream ( OutputStream os , HeadersAmp headers , String from , long qId , String address , String methodName , PodRef podCaller , ResultStream < ? > result , Object [ ] args ) throws IOException { init ( os ) ; OutH3 out = _out ; if ( out == null ) { return ; } if ( log . isLoggable ( Level . FINEST ) ) { log . finest ( "hamp-stream-w " + methodName + ( args != null ? Arrays . asList ( args ) : "[]" ) + " {to:" + address + ", from:" + from + "}" ) ; } out . writeLong ( MessageTypeHamp . STREAM . ordinal ( ) ) ; writeHeaders ( out , headers ) ; writeFromAddress ( out , from ) ; out . writeLong ( qId ) ; writeMethod ( out , address , methodName , podCaller ) ; out . writeObject ( result ) ; writeArgs ( out , args ) ; //out.flushBuffer(); out . flush ( ) ; }
Sends a stream message to a given address