Home
last modified time | relevance | path

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

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DStreamListener.java38 void messagesAvailable(MessageProducer producer); in messagesAvailable() method
DForwardingClientStreamListener.java43 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in ForwardingClientStreamListener
DApplicationThreadDeframer.java145 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable() method in ApplicationThreadDeframer
DAbstractStream.java164 public void messagesAvailable(StreamListener.MessageProducer producer) { in messagesAvailable() method in AbstractStream.TransportState
DServerCallImpl.java253 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in ServerCallImpl.ServerStreamListenerImpl
DDelayedStream.java387 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in DelayedStream.DelayedStreamListener
DServerImpl.java598 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in ServerImpl.NoopListener
675 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in ServerImpl.JumpToApplicationThreadServerStreamListener
DMessageDeframer.java67 void messagesAvailable(StreamListener.MessageProducer producer); in messagesAvailable() method
DClientCallImpl.java502 public void messagesAvailable(final MessageProducer producer) { in messagesAvailable() method in ClientCallImpl.ClientStreamListenerImpl
DRetriableStream.java681 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in RetriableStream.Sublistener
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DNoopClientStreamListener.java27 public void messagesAvailable(MessageProducer producer) {} in messagesAvailable() method in NoopClientStreamListener
DApplicationThreadDeframerTest.java153 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in ApplicationThreadDeframerTest.DeframerListener
DAbstractServerStreamTest.java335 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in AbstractServerStreamTest.ServerStreamListenerBase
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientStreamTest.java222 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in OkHttpClientStreamTest.BaseClientStreamListener
DOkHttpClientTransportTest.java1953 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in OkHttpClientTransportTest.MockStreamListener
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientTransportTest.java705 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in NettyClientTransportTest.TestClientStreamListener
728 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in NettyClientTransportTest.EchoServerStreamListener
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java1920 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in AbstractTransportTest.ServerStreamListenerBase
1977 public void messagesAvailable(MessageProducer producer) { in messagesAvailable() method in AbstractTransportTest.ClientStreamListenerBase