Home
last modified time | relevance | path

Searched refs:MessageProducer (Results 1 – 25 of 31) sorted by relevance

12

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DForwardingClientStreamListenerTest.java26 import io.grpc.internal.StreamListener.MessageProducer;
70 MessageProducer producer = mock(MessageProducer.class); in messagesAvailableTest()
DApplicationThreadDeframerTest.java31 import io.grpc.internal.StreamListener.MessageProducer;
136 private MessageProducer storedProducer;
153 public void messagesAvailable(MessageProducer producer) { in messagesAvailable()
186 private static class MultiMessageProducer implements StreamListener.MessageProducer {
DNoopClientStreamListener.java27 public void messagesAvailable(MessageProducer producer) {} in messagesAvailable()
DMessageDeframerTest.java99 private ArgumentCaptor<StreamListener.MessageProducer> producer =
100 ArgumentCaptor.forClass(StreamListener.MessageProducer.class);
139 List<StreamListener.MessageProducer> streams = producer.getAllValues(); in smallCombinedPayloads()
310 .messagesAvailable(Matchers.<StreamListener.MessageProducer>any());
DHttp2ClientStreamTransportStateTest.java65 StreamListener.MessageProducer producer = in setUp()
66 (StreamListener.MessageProducer) invocation.getArguments()[0]; in setUp()
70 }).when(mockListener).messagesAvailable(Matchers.<StreamListener.MessageProducer>any()); in setUp()
DAbstractServerStreamTest.java89 public void messagesAvailable(MessageProducer producer) { in frameShouldBeIgnoredAfterDeframerClosed()
335 public void messagesAvailable(MessageProducer producer) { in messagesAvailable()
DAbstractClientStreamTest.java84 StreamListener.MessageProducer producer = in setUp()
85 (StreamListener.MessageProducer) invocation.getArguments()[0]; in setUp()
89 }).when(mockListener).messagesAvailable(Matchers.<StreamListener.MessageProducer>any()); in setUp()
DServerImplTest.java1111 .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()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DStreamListener.java38 void messagesAvailable(MessageProducer producer); in messagesAvailable()
51 interface MessageProducer { interface
DApplicationThreadDeframer.java145 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable()
174 private class InitializingMessageProducer implements StreamListener.MessageProducer {
DForwardingClientStreamListener.java43 public void messagesAvailable(MessageProducer producer) { in messagesAvailable()
DMessageDeframer.java67 void messagesAvailable(StreamListener.MessageProducer producer); in messagesAvailable()
522 private static class SingleMessageProducer implements StreamListener.MessageProducer {
DAbstractStream.java164 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable()
DGrpcUtil.java43 import io.grpc.internal.StreamListener.MessageProducer;
714 static void closeQuietly(MessageProducer producer) {
DDelayedStream.java387 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable()
DServerCallImpl.java253 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable()
DServerImpl.java598 public void messagesAvailable(MessageProducer producer) { in messagesAvailable()
675 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java307 private ArrayDeque<StreamListener.MessageProducer> clientReceiveQueue =
308 new ArrayDeque<StreamListener.MessageProducer>();
388 StreamListener.MessageProducer producer = new SingleMessageProducer(message);
457 StreamListener.MessageProducer producer;
506 private ArrayDeque<StreamListener.MessageProducer> serverReceiveQueue =
507 new ArrayDeque<StreamListener.MessageProducer>();
574 StreamListener.MessageProducer producer = new SingleMessageProducer(message);
612 StreamListener.MessageProducer producer;
707 private static class SingleMessageProducer implements StreamListener.MessageProducer {
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DSingleMessageProducer.java23 public class SingleMessageProducer implements StreamListener.MessageProducer {
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerStreamTest.java87 StreamListener.MessageProducer producer = in setUp()
88 (StreamListener.MessageProducer) invocation.getArguments()[0]; in setUp()
97 .messagesAvailable(Matchers.<StreamListener.MessageProducer>any()); in setUp()
DNettyServerHandlerTest.java171 StreamListener.MessageProducer producer = in setUp()
172 (StreamListener.MessageProducer) invocation.getArguments()[0]; in setUp()
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()
DNettyClientStreamTest.java115 StreamListener.MessageProducer producer = in setUp()
116 (StreamListener.MessageProducer) invocation.getArguments()[0]; in setUp()
125 .messagesAvailable(Matchers.<StreamListener.MessageProducer>any()); in setUp()
DNettyClientHandlerTest.java149 StreamListener.MessageProducer producer = in setUp()
150 (StreamListener.MessageProducer) invocation.getArguments()[0]; in setUp()
159 .messagesAvailable(Matchers.<StreamListener.MessageProducer>any()); in setUp()
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetClientStreamTest.java41 import io.grpc.internal.StreamListener.MessageProducer;
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/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientStreamTest.java222 public void messagesAvailable(MessageProducer producer) { in messagesAvailable()

12