MigratingThreadDeframer.DeframeMessageProducer

java.lang.Object
- io.grpc.internal.MigratingThreadDeframer.DeframeMessageProducer

All Implemented Interfaces:: StreamListener.MessageProducer, java.io.Closeable, java.lang.AutoCloseable

Enclosing class:: MigratingThreadDeframer

class MigratingThreadDeframer.DeframeMessageProducer
extends java.lang.Object
implements StreamListener.MessageProducer, java.io.Closeable

Constructor Summary

Constructors
Constructor Description

DeframeMessageProducer()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`
`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.

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

- Constructor Detail
  - DeframeMessageProducer
```
DeframeMessageProducer()
```
- Method Detail
  - next
```
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 interface StreamListener.MessageProducer
  - close
```
public void close()
```
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Specified by:
    
    close in interface java.io.Closeable