Class MigratingThreadDeframer.DeframeMessageProducer

java.lang.Object
io.grpc.internal.MigratingThreadDeframer.DeframeMessageProducer
All Implemented Interfaces:
StreamListener.MessageProducer, Closeable, AutoCloseable
Enclosing class:
MigratingThreadDeframer

class MigratingThreadDeframer.DeframeMessageProducer extends Object implements StreamListener.MessageProducer, Closeable
  • Constructor Details

    • DeframeMessageProducer

      DeframeMessageProducer()
  • Method Details

    • next

      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
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable