| Modifier and Type | Method and Description |
|---|---|
| public void | |
| public void | |
| public void | updateCapacity(CapacityChannel
the channel for capacity updates. capacityChannel)Triggered to signal ability of the underlying data stream to receive data capacity update. |
| consume | back to summary |
|---|---|
| public void consume(ByteBuffer src) throws IOException Triggered to pass incoming data to the data consumer. The consumer must consume the entire content of the data buffer. The consumer must stop incrementing its capacity on the capacity channel if it is unable to accept more data. Once the data consumer has handled accumulated data or allocated more intermediate storage it can update its capacity information on the capacity channel.
| |
| streamEnd | back to summary |
|---|---|
| public void streamEnd(List<? extends Header> trailers) throws HttpException, IOException Triggered to signal termination of the data stream. | |
| updateCapacity | back to summary |
|---|---|
| public void updateCapacity(CapacityChannel capacityChannel) throws IOException Triggered to signal ability of the underlying data stream to receive data capacity update. The data consumer can choose to write data immediately inside the call or asynchronously at some later point.
| |