AbstractIoUringStreamChannel.IovBufferCollector

java.lang.Object
- io.netty.channel.uring.AbstractIoUringStreamChannel.IovBufferCollector

All Implemented Interfaces:

ChannelOutboundBuffer.MessageProcessor

Enclosing class:

AbstractIoUringStreamChannel
```
static final class AbstractIoUringStreamChannel.IovBufferCollector
extends java.lang.Object
implements ChannelOutboundBuffer.MessageProcessor
```
Collects and retains the messages backing a submitted iov prefix. Keep the non-empty NIO segment counting aligned with IovArray.add(ByteBuf, int, int). The readable ranges must still match those used at submission; the shared iov memory itself may already have been reused.

Field Summary

Fields
Modifier and Type Field Description

private java.util.List<ReferenceCounted> buffers

private int remaining

Constructor Summary

Constructors
Constructor Description

IovBufferCollector()

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`(package private) java.util.List<ReferenceCounted>`	`collect(ChannelOutboundBuffer buffer, int count)`
`boolean`	`processMessage(java.lang.Object msg)`	Will be called for each flushed message until it either there are no more flushed messages or this method returns `false`.
`(package private) static int`	`remainingIovs(ByteBuf buf, int remaining)`

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

- Field Detail
  - buffers
```
private java.util.List<ReferenceCounted> buffers
```
  - remaining
```
private int remaining
```
- Constructor Detail
  - IovBufferCollector
```
IovBufferCollector()
```
- Method Detail
  - collect
```
java.util.List<ReferenceCounted> collect(ChannelOutboundBuffer buffer,
                                         int count)
```
  - processMessage
```
public boolean processMessage(java.lang.Object msg)
```
    Description copied from interface: ChannelOutboundBuffer.MessageProcessor
    
    Will be called for each flushed message until it either there are no more flushed messages or this method returns false.
    
    Specified by:
    
    processMessage in interface ChannelOutboundBuffer.MessageProcessor
  - remainingIovs
```
static int remainingIovs(ByteBuf buf,
                         int remaining)
```