Uses of Interface
io.grpc.internal.StreamListener.MessageProducer
Packages that use StreamListener.MessageProducer
Package
Description
The in-process transport which is for when a server is in the same process as the client.
Interfaces and implementations that are internal to gRPC.
-
Uses of StreamListener.MessageProducer in io.grpc.inprocess
Classes in io.grpc.inprocess that implement StreamListener.MessageProducerFields in io.grpc.inprocess with type parameters of type StreamListener.MessageProducerModifier and TypeFieldDescriptionprivate ArrayDeque
<StreamListener.MessageProducer> InProcessTransport.InProcessStream.InProcessServerStream.clientReceiveQueue
private ArrayDeque
<StreamListener.MessageProducer> InProcessTransport.InProcessStream.InProcessClientStream.serverReceiveQueue
-
Uses of StreamListener.MessageProducer in io.grpc.internal
Classes in io.grpc.internal that implement StreamListener.MessageProducerModifier and TypeClassDescriptionprivate class
private class
private static class
(package private) class
Methods in io.grpc.internal with parameters of type StreamListener.MessageProducerModifier and TypeMethodDescription(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)