Package io.grpc.internal
Interface StreamListener.MessageProducer
-
- All Known Implementing Classes:
ApplicationThreadDeframer.CloseableInitializingMessageProducer
,ApplicationThreadDeframer.InitializingMessageProducer
,InProcessTransport.SingleMessageProducer
,MessageDeframer.SingleMessageProducer
,MigratingThreadDeframer.DeframeMessageProducer
- Enclosing interface:
- StreamListener
public static interface StreamListener.MessageProducer
A producer for deframed gRPC messages.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description 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
-
next
@Nullable 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.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.
-
-