Package io.grpc.internal
Class ApplicationThreadDeframer.InitializingMessageProducer
java.lang.Object
io.grpc.internal.ApplicationThreadDeframer.InitializingMessageProducer
- All Implemented Interfaces:
StreamListener.MessageProducer
- Direct Known Subclasses:
ApplicationThreadDeframer.CloseableInitializingMessageProducer
- Enclosing class:
ApplicationThreadDeframer
private class ApplicationThreadDeframer.InitializingMessageProducer
extends Object
implements StreamListener.MessageProducer
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
next()
Returns the next gRPC message, if the data has been received by the deframer and the application has requested another message.
-
Field Details
-
runnable
-
initialized
private boolean initialized
-
-
Constructor Details
-
InitializingMessageProducer
-
-
Method Details
-
initialize
private void initialize() -
next
Description copied from interface:StreamListener.MessageProducer
Returns the next gRPC message, if the data has been received by the deframer and the application has requested another message.The provided
message
InputStream
must be closed by the listener.This is intended to be used similar to an iterator, invoking
next()
to obtain messages until the producer returns null, at which point the producer may be discarded.- Specified by:
next
in interfaceStreamListener.MessageProducer
-