Home
last modified time | relevance | path

Searched defs:messagesAvailable (Results 1 – 21 of 21) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DStreamListener.java38 void messagesAvailable(MessageProducer producer); in messagesAvailable() method
DForwardingDeframerListener.java31 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable() method in ForwardingDeframerListener
DSquelchLateMessagesAvailableDeframerListener.java42 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable() method in SquelchLateMessagesAvailableDeframerListener
DForwardingClientStreamListener.java38 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in ForwardingClientStreamListener
DApplicationThreadDeframerListener.java61 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable() method in ApplicationThreadDeframerListener
DAbstractStream.java182 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable() method in AbstractStream.TransportState
DServerCallImpl.java306 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in ServerCallImpl.ServerStreamListenerImpl
DServerImpl.java738 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in ServerImpl.NoopListener
817 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in ServerImpl.JumpToApplicationThreadServerStreamListener
DMessageDeframer.java68 void messagesAvailable(StreamListener.MessageProducer producer); in messagesAvailable() method
DClientCallImpl.java632 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in ClientCallImpl.ClientStreamListenerImpl
DRetriableStream.java1088 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in RetriableStream.Sublistener
/external/grpc-grpc-java/core/src/testFixtures/java/io/grpc/internal/
DNoopClientStreamListener.java27 public void messagesAvailable(MessageProducer producer) {} in messagesAvailable() method in NoopClientStreamListener
DAbstractTransportTest.java2252 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in AbstractTransportTest.ServerStreamListenerBase
2309 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in AbstractTransportTest.ClientStreamListenerBase
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientStreamTest.java268 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in OkHttpClientStreamTest.BaseClientStreamListener
DOkHttpServerTransportTest.java1319 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in OkHttpServerTransportTest.MockStreamListener
DOkHttpClientTransportTest.java2228 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in OkHttpClientTransportTest.MockStreamListener
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetClientTransportTest.java161 public void messagesAvailable(MessageProducer producer) {} in messagesAvailable() method in CronetClientTransportTest.BaseClientStreamListener
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DApplicationThreadDeframerTest.java152 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in ApplicationThreadDeframerTest.DeframerListener
DAbstractServerStreamTest.java376 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in AbstractServerStreamTest.ServerStreamListenerBase
/external/grpc-grpc-java/binder/src/androidTest/java/io/grpc/binder/internal/
DBinderClientTransportTest.java340 public void messagesAvailable(StreamListener.MessageProducer messageProducer) { in messagesAvailable() method in BinderClientTransportTest.TestStreamListener
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientTransportTest.java868 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in NettyClientTransportTest.TestClientStreamListener
889 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in NettyClientTransportTest.EchoServerStreamListener