Object function ( final EmbeddedChannel arg0 ) { return CommonUtils . waitForResult ( "srini_string" , new Function < Void , Object > ( ) { @ Override public Object apply ( Void arg1 ) { return arg0 . readOutbound ( ) ; } } , WaitForOptions . defaults ( ) . setTimeout ( Constants . MINUTE_MS ) ) ; }
waits for a response . concode_field_sep EmbeddedChannel mChannel concode_elem_sep int PACKET_SIZE concode_elem_sep String mFile concode_elem_sep long mChecksum concode_elem_sep EmbeddedChannel mChannelNoException concode_elem_sep TemporaryFolder mTestFolder concode_field_sep void writeNonEmptyFile concode_elem_sep void writeInvalidOffset concode_elem_sep void checkFileContent concode_elem_sep void checkWriteResponse concode_elem_sep RPCProtoMessage buildWriteRequest concode_elem_sep void writeEmptyFile