Top Description Inners Constructors Methods
io.netty5.channel.kqueue

public final Class KQueueReadHandleFactory

extends MaxMessagesReadHandleFactory
Class Inheritance
Imports
io.netty5.channel.MaxMessagesReadHandleFactory
MaxMessagesReadHandleFactory which always try to allocate buffers as big as kqueue tells us in terms of pending bytes to read.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
KQueueReadHandleFactory.KQueueReadHandle

Constructor Summary

AccessConstructor and Description
public
KQueueReadHandleFactory()

public
KQueueReadHandleFactory(int maxMessagesPerRead)

Method Summary

Modifier and TypeMethod and Description
public MaxMessagesReadHandleFactory.MaxMessageReadHandle
newMaxMessageHandle(int
the maximum number of messages to read per read loop.
maxMessagesPerRead)

Implements abstract io.netty5.channel.MaxMessagesReadHandleFactory.newMaxMessageHandle.

Creates a new MaxMessageReadHandle to use.
Inherited from io.netty5.channel.MaxMessagesReadHandleFactory:
newHandle

Constructor Detail

KQueueReadHandleFactoryback to summary
public KQueueReadHandleFactory()
KQueueReadHandleFactoryback to summary
public KQueueReadHandleFactory(int maxMessagesPerRead)

Method Detail

newMaxMessageHandleback to summary
public MaxMessagesReadHandleFactory.MaxMessageReadHandle newMaxMessageHandle(int maxMessagesPerRead)

Implements abstract io.netty5.channel.MaxMessagesReadHandleFactory.newMaxMessageHandle.

Doc from io.netty5.channel.MaxMessagesReadHandleFactory.newMaxMessageHandle.

Creates a new MaxMessageReadHandle to use.

Parameters
maxMessagesPerRead:int

the maximum number of messages to read per read loop.

Returns:MaxMessagesReadHandleFactory.MaxMessageReadHandle

the handle.

Annotations
@Override
io.netty5.channel.kqueue back to summary

pack-priv final Class KQueueReadHandleFactory.KQueueReadHandle

extends MaxMessageReadHandle
Class Inheritance

Field Summary

Modifier and TypeField and Description
private int
capacity

Constructor Summary

AccessConstructor and Description
pack-priv
KQueueReadHandle(int maxMessagesPerRead)

Method Summary

Modifier and TypeMethod and Description
pack-priv void
bufferCapacity(int capacity)

public int
estimatedBufferCapacity()

Implements io.netty5.channel.ReadHandleFactory.ReadHandle.estimatedBufferCapacity.

Guess the capacity for the next receive buffer that is probably large enough to read all inbound data and small enough not to waste its space.
Inherited from io.netty5.channel.MaxMessagesReadHandleFactory.MaxMessageReadHandle:
lastReadreadComplete

Field Detail

capacityback to summary
private int capacity

Constructor Detail

KQueueReadHandleback to summary
pack-priv KQueueReadHandle(int maxMessagesPerRead)

Method Detail

bufferCapacityback to summary
pack-priv void bufferCapacity(int capacity)
estimatedBufferCapacityback to summary
public int estimatedBufferCapacity()

Implements io.netty5.channel.ReadHandleFactory.ReadHandle.estimatedBufferCapacity.

Doc from io.netty5.channel.ReadHandleFactory.ReadHandle.estimatedBufferCapacity.

Guess the capacity for the next receive buffer that is probably large enough to read all inbound data and small enough not to waste its space.

Annotations
@Override