Searched refs:largeMessage (Results 1 – 2 of 2) sorted by relevance
152 byte[] msg = largeMessage(); in notifiedOnReadyAfterWriteCompletes()184 byte[] msg = largeMessage(); in shouldNotBeReadyForDataAfterWritingLargeMessage()195 protected byte[] largeMessage() { in largeMessage() method in NettyStreamTestBase198 byte[] largeMessage = new byte[size]; in largeMessage()200 System.arraycopy(smallMessage, 0, largeMessage, ix, smallMessage.length); in largeMessage()202 return largeMessage; in largeMessage()
1224 String largeMessage; in flowControlPushBack() local1231 largeMessage = sb.toString(); in flowControlPushBack()1246 clientStream.writeMessage(methodDescriptor.streamRequest(largeMessage)); in flowControlPushBack()1252 clientStream.writeMessage(methodDescriptor.streamResponse(largeMessage)); in flowControlPushBack()1270 serverStream.writeMessage(methodDescriptor.streamResponse(largeMessage)); in flowControlPushBack()1276 serverStream.writeMessage(methodDescriptor.streamResponse(largeMessage)); in flowControlPushBack()1304 clientStream.writeMessage(methodDescriptor.streamRequest(largeMessage)); in flowControlPushBack()1306 serverStream.writeMessage(methodDescriptor.streamResponse(largeMessage)); in flowControlPushBack()1320 clientStream.writeMessage(methodDescriptor.streamRequest(largeMessage)); in flowControlPushBack()1331 serverStream.writeMessage(methodDescriptor.streamResponse(largeMessage)); in flowControlPushBack()