Home
last modified time | relevance | path

Searched refs:StreamListener (Results 1 – 22 of 22) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java53 import io.grpc.internal.StreamListener;
306 private ArrayDeque<StreamListener.MessageProducer> clientReceiveQueue =
307 new ArrayDeque<StreamListener.MessageProducer>();
387 StreamListener.MessageProducer producer = new SingleMessageProducer(message);
456 StreamListener.MessageProducer producer;
505 private ArrayDeque<StreamListener.MessageProducer> serverReceiveQueue =
506 new ArrayDeque<StreamListener.MessageProducer>();
573 StreamListener.MessageProducer producer = new SingleMessageProducer(message);
611 StreamListener.MessageProducer producer;
706 private static class SingleMessageProducer implements StreamListener.MessageProducer {
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DSingleMessageProducer.java19 import io.grpc.internal.StreamListener;
23 public class SingleMessageProducer implements StreamListener.MessageProducer {
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DApplicationThreadDeframer.java145 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable()
174 private class InitializingMessageProducer implements StreamListener.MessageProducer {
DAbstractStream.java161 protected abstract StreamListener listener(); in listener()
164 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable()
DServerStreamListener.java22 public interface ServerStreamListener extends StreamListener {
DStreamListener.java26 public interface StreamListener { interface
DClientStreamListener.java23 public interface ClientStreamListener extends StreamListener {
DMessageDeframer.java67 void messagesAvailable(StreamListener.MessageProducer producer); in messagesAvailable()
522 private static class SingleMessageProducer implements StreamListener.MessageProducer {
DGrpcUtil.java43 import io.grpc.internal.StreamListener.MessageProducer;
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerStreamTest.java42 import io.grpc.internal.StreamListener;
87 StreamListener.MessageProducer producer = in setUp()
88 (StreamListener.MessageProducer) invocation.getArguments()[0]; in setUp()
97 .messagesAvailable(Matchers.<StreamListener.MessageProducer>any()); in setUp()
DNettyStreamTestBase.java33 import io.grpc.internal.StreamListener;
209 protected abstract StreamListener listener(); in listener()
DNettyServerHandlerTest.java67 import io.grpc.internal.StreamListener;
171 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.java53 import io.grpc.internal.StreamListener;
115 StreamListener.MessageProducer producer = in setUp()
116 (StreamListener.MessageProducer) invocation.getArguments()[0]; in setUp()
125 .messagesAvailable(Matchers.<StreamListener.MessageProducer>any()); in setUp()
DNettyClientHandlerTest.java66 import io.grpc.internal.StreamListener;
149 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/core/src/test/java/io/grpc/internal/
DApplicationThreadDeframerTest.java31 import io.grpc.internal.StreamListener.MessageProducer;
186 private static class MultiMessageProducer implements StreamListener.MessageProducer {
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());
DForwardingClientStreamListenerTest.java26 import io.grpc.internal.StreamListener.MessageProducer;
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()
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()
DRetriableStreamTest.java57 import io.grpc.internal.StreamListener.MessageProducer;
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetClientStreamTest.java41 import io.grpc.internal.StreamListener.MessageProducer;