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 java.lang.Object implements StreamListener.MessageProducer
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
initialized
private java.lang.Runnable
runnable
-
Constructor Summary
Constructors Modifier Constructor Description private
InitializingMessageProducer(java.lang.Runnable runnable)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
initialize()
java.io.InputStream
next()
Returns the next gRPC message, if the data has been received by the deframer and the application has requested another message.
-
-
-
Method Detail
-
initialize
private void initialize()
-
next
@Nullable public java.io.InputStream 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
-
-