Searched refs:StreamListener (Results 1 – 22 of 22) sorted by relevance
53 import io.grpc.internal.StreamListener;307 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 {
19 import io.grpc.internal.StreamListener;23 public class SingleMessageProducer implements StreamListener.MessageProducer {
145 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable()174 private class InitializingMessageProducer implements StreamListener.MessageProducer {
161 protected abstract StreamListener listener(); in listener()164 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable()
22 public interface ServerStreamListener extends StreamListener {
26 public interface StreamListener { interface
23 public interface ClientStreamListener extends StreamListener {
67 void messagesAvailable(StreamListener.MessageProducer producer); in messagesAvailable()522 private static class SingleMessageProducer implements StreamListener.MessageProducer {
43 import io.grpc.internal.StreamListener.MessageProducer;
42 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()
33 import io.grpc.internal.StreamListener;209 protected abstract StreamListener listener(); in listener()
67 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()
53 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()
66 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()
31 import io.grpc.internal.StreamListener.MessageProducer;186 private static class MultiMessageProducer implements StreamListener.MessageProducer {
99 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());
26 import io.grpc.internal.StreamListener.MessageProducer;
65 StreamListener.MessageProducer producer = in setUp()66 (StreamListener.MessageProducer) invocation.getArguments()[0]; in setUp()70 }).when(mockListener).messagesAvailable(Matchers.<StreamListener.MessageProducer>any()); in setUp()
84 StreamListener.MessageProducer producer = in setUp()85 (StreamListener.MessageProducer) invocation.getArguments()[0]; in setUp()89 }).when(mockListener).messagesAvailable(Matchers.<StreamListener.MessageProducer>any()); in setUp()
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()
57 import io.grpc.internal.StreamListener.MessageProducer;
41 import io.grpc.internal.StreamListener.MessageProducer;