Class KQueueRecvByteAllocatorHandle

java.lang.Object

io.netty.channel.RecvByteBufAllocator.DelegatingHandle

io.netty.channel.kqueue.KQueueRecvByteAllocatorHandle

All Implemented Interfaces:

RecvByteBufAllocator.ExtendedHandle, RecvByteBufAllocator.Handle

final class KQueueRecvByteAllocatorHandle
extends RecvByteBufAllocator.DelegatingHandle
implements RecvByteBufAllocator.ExtendedHandle

Field Summary

Fields

Modifier and Type	Field	Description
private final UncheckedBooleanSupplier	defaultMaybeMoreDataSupplier
private long	numberBytesPending
private final PreferredDirectByteBufAllocator	preferredDirectByteBufAllocator
private boolean	readEOF

Constructor Summary

Constructors

Constructor	Description
KQueueRecvByteAllocatorHandle(RecvByteBufAllocator.ExtendedHandle handle)

Method Summary

Modifier and Type	Method	Description
ByteBuf	allocate(ByteBufAllocator alloc)	Creates a new receive buffer whose capacity is probably large enough to read all inbound data and small enough not to waste its space.
boolean	continueReading()	Determine if the current read loop should continue.
boolean	continueReading(UncheckedBooleanSupplier maybeMoreDataSupplier)	Same as RecvByteBufAllocator.Handle.continueReading() except "more data" is determined by the supplier parameter.
(package private) boolean	isReadEOF()
private boolean	maybeMoreDataToRead()
(package private) void	numberBytesPending(long numberBytesPending)
(package private) void	readEOF()

Methods inherited from class RecvByteBufAllocator.DelegatingHandle

attemptedBytesRead, attemptedBytesRead, delegate, guess, incMessagesRead, lastBytesRead, lastBytesRead, readComplete, reset

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface RecvByteBufAllocator.Handle

attemptedBytesRead, attemptedBytesRead, guess, incMessagesRead, lastBytesRead, lastBytesRead, readComplete, reset

Field Details

preferredDirectByteBufAllocator

private final PreferredDirectByteBufAllocator preferredDirectByteBufAllocator

defaultMaybeMoreDataSupplier

private final UncheckedBooleanSupplier defaultMaybeMoreDataSupplier

readEOF

private boolean readEOF

numberBytesPending

private long numberBytesPending

Constructor Details

KQueueRecvByteAllocatorHandle

KQueueRecvByteAllocatorHandle(RecvByteBufAllocator.ExtendedHandle handle)

Method Details

allocate

public ByteBuf allocate(ByteBufAllocator alloc)

Description copied from interface: RecvByteBufAllocator.Handle

Creates a new receive buffer whose capacity is probably large enough to read all inbound data and small enough not to waste its space.

Specified by:

allocate in interface RecvByteBufAllocator.Handle

Overrides:

allocate in class RecvByteBufAllocator.DelegatingHandle

continueReading

public boolean continueReading(UncheckedBooleanSupplier maybeMoreDataSupplier)

Description copied from interface: RecvByteBufAllocator.ExtendedHandle

Same as RecvByteBufAllocator.Handle.continueReading() except "more data" is determined by the supplier parameter.

Specified by:

continueReading in interface RecvByteBufAllocator.ExtendedHandle

Parameters:

maybeMoreDataSupplier - A supplier that determines if there maybe more data to read.

continueReading

public boolean continueReading()

Description copied from interface: RecvByteBufAllocator.Handle

Determine if the current read loop should continue.

Specified by:

continueReading in interface RecvByteBufAllocator.Handle

Overrides:

continueReading in class RecvByteBufAllocator.DelegatingHandle

Returns:

true if the read loop should continue reading. false if the read loop is complete.

readEOF

void readEOF()

isReadEOF

boolean isReadEOF()

numberBytesPending

void numberBytesPending(long numberBytesPending)

maybeMoreDataToRead

private boolean maybeMoreDataToRead()