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 Details

    • runnable

      private final Runnable runnable
    • initialized

      private boolean initialized
  • Constructor Details

    • InitializingMessageProducer

      private InitializingMessageProducer(Runnable runnable)
  • Method Details

    • initialize

      private void initialize()
    • next

      @Nullable public 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 interface StreamListener.MessageProducer