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 Summary

Constructors

Constructor

Description

DeframeMessageProducer()
Method Summary

Modifier and Type

Method

Description

void

close()

InputStream

next()

Returns the next gRPC message, if the data has been received by the deframer and the application has requested another message.

Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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