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 java.lang.Object
implements StreamListener.MessageProducer
```

Field Summary

Fields
Modifier and Type Field Description

private boolean initialized

private java.lang.Runnable runnable

Constructor Summary

Constructors
Modifier Constructor Description

private InitializingMessageProducer(java.lang.Runnable runnable)

Method Summary

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

- Field Detail
  - runnable
```
private final java.lang.Runnable runnable
```
  - initialized
```
private boolean initialized
```
- Constructor Detail
  - InitializingMessageProducer
```
private InitializingMessageProducer(java.lang.Runnable runnable)
```
- Method Detail
  - initialize
```
private void initialize()
```
  - next
```
@Nullable
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