Home
last modified time | relevance | path

Searched refs:streamRequest (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerCallImplTest.java418 streamListener.messagesAvailable(new SingleMessageProducer(UNARY_METHOD.streamRequest(1234L))); in streamListener_messageRead()
427 streamListener.messagesAvailable(new SingleMessageProducer(UNARY_METHOD.streamRequest(1234L))); in streamListener_messageRead_onlyOnce()
431 streamListener.messagesAvailable(new SingleMessageProducer(UNARY_METHOD.streamRequest(1234L))); in streamListener_messageRead_onlyOnce()
444 InputStream inputStream = UNARY_METHOD.streamRequest(1234L); in streamListener_unexpectedRuntimeException()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java258 stream.writeMessage(methodDescriptor.streamRequest("foo")); in frameAfterRstStreamShouldNotBreakClientChannel()
714 clientStream.writeMessage(methodDescriptor.streamRequest("Hello!")); in basicStream()
1128 serverStream.writeMessage(methodDescriptor.streamRequest("foo")); in clientCancelFromWithinMessageRead()
1245 clientStream.writeMessage(methodDescriptor.streamRequest(largeMessage)); in flowControlPushBack()
1303 clientStream.writeMessage(methodDescriptor.streamRequest(largeMessage)); in flowControlPushBack()
1319 clientStream.writeMessage(methodDescriptor.streamRequest(largeMessage)); in flowControlPushBack()
1418 clientStream.writeMessage(methodDescriptor.streamRequest("request")); in interactionsAfterClientStreamCancelAreNoops()
1648 clientStream.writeMessage(methodDescriptor.streamRequest("request")); in transportTracer_server_receive_msg()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DMethodDescriptor.java277 public InputStream streamRequest(ReqT requestMessage) { in streamRequest() method in MethodDescriptor
DServerInterceptors.java283 final InputStream is = wrappedMethod.streamRequest(message); in wrapHandler()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DRetriableStream.java336 savedState.winningSubstream.stream.writeMessage(method.streamRequest(message)); in sendMessage()
343 substream.stream.writeMessage(method.streamRequest(message)); in sendMessage()
DClientCallImpl.java422 stream.writeMessage(method.streamRequest(message)); in sendMessage()