Uses of Interface
io.grpc.internal.StreamListener.MessageProducer
-
Packages that use StreamListener.MessageProducer Package Description io.grpc.inprocess The in-process transport which is for when a server is in the same process as the client.io.grpc.internal Interfaces and implementations that are internal to gRPC. -
-
Uses of StreamListener.MessageProducer in io.grpc.inprocess
Classes in io.grpc.inprocess that implement StreamListener.MessageProducer Modifier and Type Class Description private static class
InProcessTransport.SingleMessageProducer
Fields in io.grpc.inprocess with type parameters of type StreamListener.MessageProducer Modifier and Type Field Description private java.util.ArrayDeque<StreamListener.MessageProducer>
InProcessTransport.InProcessStream.InProcessServerStream. clientReceiveQueue
private java.util.ArrayDeque<StreamListener.MessageProducer>
InProcessTransport.InProcessStream.InProcessClientStream. serverReceiveQueue
-
Uses of StreamListener.MessageProducer in io.grpc.internal
Classes in io.grpc.internal that implement StreamListener.MessageProducer Modifier and Type Class Description private class
ApplicationThreadDeframer.CloseableInitializingMessageProducer
private class
ApplicationThreadDeframer.InitializingMessageProducer
private static class
MessageDeframer.SingleMessageProducer
(package private) class
MigratingThreadDeframer.DeframeMessageProducer
Methods in io.grpc.internal with parameters of type StreamListener.MessageProducer Modifier and Type Method Description (package private) static void
GrpcUtil. closeQuietly(StreamListener.MessageProducer producer)
Quietly closes all messages in MessageProducer.void
AbstractStream.TransportState. messagesAvailable(StreamListener.MessageProducer producer)
void
ApplicationThreadDeframerListener. messagesAvailable(StreamListener.MessageProducer producer)
void
ClientCallImpl.ClientStreamListenerImpl. messagesAvailable(StreamListener.MessageProducer producer)
void
DelayedStream.DelayedStreamListener. messagesAvailable(StreamListener.MessageProducer producer)
void
ForwardingClientStreamListener. messagesAvailable(StreamListener.MessageProducer producer)
void
ForwardingDeframerListener. messagesAvailable(StreamListener.MessageProducer producer)
void
MessageDeframer.Listener. messagesAvailable(StreamListener.MessageProducer producer)
Called to deliver the next complete message.void
RetriableStream.Sublistener. messagesAvailable(StreamListener.MessageProducer producer)
void
ServerCallImpl.ServerStreamListenerImpl. messagesAvailable(StreamListener.MessageProducer producer)
void
ServerImpl.JumpToApplicationThreadServerStreamListener. messagesAvailable(StreamListener.MessageProducer producer)
void
ServerImpl.NoopListener. messagesAvailable(StreamListener.MessageProducer producer)
void
SquelchLateMessagesAvailableDeframerListener. messagesAvailable(StreamListener.MessageProducer producer)
void
StreamListener. messagesAvailable(StreamListener.MessageProducer producer)
Called upon receiving a message from the remote end-point.private void
ServerCallImpl.ServerStreamListenerImpl. messagesAvailableInternal(StreamListener.MessageProducer producer)
-