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 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.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)