| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ApplicationThreadDeframer.java | 73 storedListener.messagesAvailable( in request()
93 storedListener.messagesAvailable( in deframe()
110 storedListener.messagesAvailable( in closeWhenComplete()
123 storedListener.messagesAvailable( in close()
145 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable() method in ApplicationThreadDeframer
|
| D | ForwardingClientStreamListener.java | 43 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in ForwardingClientStreamListener
44 delegate().messagesAvailable(producer); in messagesAvailable()
|
| D | DelayedStream.java | 387 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in DelayedStream.DelayedStreamListener
389 realListener.messagesAvailable(producer); in messagesAvailable()
394 realListener.messagesAvailable(producer); in messagesAvailable()
|
| D | AbstractStream.java | 164 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable() method in AbstractStream.TransportState
165 listener().messagesAvailable(producer); in messagesAvailable()
|
| D | StreamListener.java | 38 void messagesAvailable(MessageProducer producer); in messagesAvailable() method
|
| D | MessageDeframer.java | 67 void messagesAvailable(StreamListener.MessageProducer producer); in messagesAvailable() method
408 listener.messagesAvailable(new SingleMessageProducer(stream)); in processBody()
|
| D | ServerImpl.java | 598 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in ServerImpl.NoopListener
675 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in ServerImpl.JumpToApplicationThreadServerStreamListener
686 getListener().messagesAvailable(producer); in messagesAvailable()
|
| D | ServerCallImpl.java | 253 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in ServerCallImpl.ServerStreamListenerImpl
|
| D | RetriableStream.java | 681 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in RetriableStream.Sublistener
688 masterListener.messagesAvailable(producer); in messagesAvailable()
|
| D | ClientCallImpl.java | 502 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in ClientCallImpl.ClientStreamListenerImpl
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | MessageDeframerTest.java | 127 verify(listener).messagesAvailable(producer.capture()); in simplePayload()
138 verify(listener, times(2)).messagesAvailable(producer.capture()); in smallCombinedPayloads()
153 verify(listener).messagesAvailable(producer.capture()); in endOfStreamWithPayloadShouldNotifyEndOfStream()
209 verify(listener).messagesAvailable(producer.capture()); in payloadSplitBetweenBuffers()
234 verify(listener).messagesAvailable(producer.capture()); in frameHeaderSplitBetweenBuffers()
245 verify(listener).messagesAvailable(producer.capture()); in emptyPayload()
257 verify(listener).messagesAvailable(producer.capture()); in largerFrameSize()
275 verify(listener).messagesAvailable(producer.capture()); in endOfStreamCallbackShouldWaitForMessageDelivery()
293 verify(listener).messagesAvailable(producer.capture()); in compressed()
310 .messagesAvailable(Matchers.<StreamListener.MessageProducer>any());
[all …]
|
| D | DelayedStreamTest.java | 314 passedListener.messagesAvailable(producer1); in listener_allQueued()
316 passedListener.messagesAvailable(producer2); in listener_allQueued()
324 inOrder.verify(listener).messagesAvailable(producer1); in listener_allQueued()
326 inOrder.verify(listener).messagesAvailable(producer2); in listener_allQueued()
346 delayedListener.messagesAvailable(producer); in listener_noQueued()
347 verify(listener).messagesAvailable(producer); in listener_noQueued()
|
| D | ForwardingClientStreamListenerTest.java | 71 forward.messagesAvailable(producer); in messagesAvailableTest()
72 verify(mock).messagesAvailable(same(producer)); in messagesAvailableTest()
|
| D | ApplicationThreadDeframerTest.java | 125 applicationThreadDeframer.messagesAvailable(messageProducer); in messagesAvailableDrainsToMessageReadQueue_returnedByInitializingMessageProducer()
153 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in ApplicationThreadDeframerTest.DeframerListener
|
| D | ServerCallImplTest.java | 418 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()
448 streamListener.messagesAvailable(new SingleMessageProducer(inputStream)); in streamListener_unexpectedRuntimeException()
|
| D | NoopClientStreamListener.java | 27 public void messagesAvailable(MessageProducer producer) {} in messagesAvailable() method in NoopClientStreamListener
|
| D | AbstractServerStreamTest.java | 89 public void messagesAvailable(MessageProducer producer) { in frameShouldBeIgnoredAfterDeframerClosed()
335 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in AbstractServerStreamTest.ServerStreamListenerBase
|
| D | ServerImplTest.java | 520 streamListener.messagesAvailable(new SingleMessageProducer(STRING_MARSHALLER.stream(request))); in basicExchangeHelper()
922 .messagesAvailable(new SingleMessageProducer(new ByteArrayInputStream(new byte[0]))); in testCallContextIsBoundInListenerCallbacks()
1111 .messagesAvailable(any(StreamListener.MessageProducer.class)); in messageRead_errorCancelsCall()
1113 listener.messagesAvailable(mock(StreamListener.MessageProducer.class)); in messageRead_errorCancelsCall()
1136 .messagesAvailable(any(StreamListener.MessageProducer.class)); in messageRead_runtimeExceptionCancelsCall()
1138 listener.messagesAvailable(mock(StreamListener.MessageProducer.class)); in messageRead_runtimeExceptionCancelsCall()
|
| D | ClientCallImplTest.java | 191 .messagesAvailable(new SingleMessageProducer(new ByteArrayInputStream(new byte[]{}))); in exceptionInOnMessageTakesPrecedenceOverServer()
565 listener.messagesAvailable(new SingleMessageProducer(new ByteArrayInputStream(new byte[0]))); in callerContextPropagatedToListener()
566 listener.messagesAvailable(new SingleMessageProducer(new ByteArrayInputStream(new byte[0]))); in callerContextPropagatedToListener()
905 .messagesAvailable(new SingleMessageProducer(new ByteArrayInputStream(new byte[0]))); in cancelInOnMessageShouldInvokeStreamCancel()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 358 clientStreamListener.messagesAvailable(clientReceiveQueue.poll());
390 clientStreamListener.messagesAvailable(producer);
549 serverStreamListener.messagesAvailable(serverReceiveQueue.poll());
576 serverStreamListener.messagesAvailable(producer);
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 260 verify(clientListener, times(0)).messagesAvailable(isA(MessageProducer.class)); in read()
264 verify(clientListener, times(1)).messagesAvailable(isA(MessageProducer.class)); in read()
270 verify(clientListener, times(1)).messagesAvailable(isA(MessageProducer.class)); in read()
310 verify(clientListener, times(1)).messagesAvailable(isA(MessageProducer.class)); in streamSucceeded()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerHandlerTest.java | 181 .messagesAvailable(any(StreamListener.MessageProducer.class)); in setUp()
261 .messagesAvailable(any(StreamListener.MessageProducer.class)); in inboundDataShouldForwardToStreamListener()
283 .messagesAvailable(any(StreamListener.MessageProducer.class)); in clientHalfCloseShouldForwardToStreamListener()
316 doThrow(e).when(streamListener).messagesAvailable(any(StreamListener.MessageProducer.class)); in streamErrorShouldNotCloseChannel()
|
| D | NettyClientTransportTest.java | 705 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in NettyClientTransportTest.TestClientStreamListener
728 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in NettyClientTransportTest.EchoServerStreamListener
|
| D | NettyServerStreamTest.java | 97 .messagesAvailable(Matchers.<StreamListener.MessageProducer>any()); in setUp()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientStreamTest.java | 222 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in OkHttpClientStreamTest.BaseClientStreamListener
|