io.netty.channel

类 DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle

java.lang.Object

io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle

所有已实现的接口:

RecvByteBufAllocator.ExtendedHandle, RecvByteBufAllocator.Handle

封闭类:

DefaultMaxMessagesRecvByteBufAllocator

public abstract class DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle
extends java.lang.Object
implements RecvByteBufAllocator.ExtendedHandle

Focuses on enforcing the maximum messages per read condition for continueReading().

构造器概要

构造器

构造器和说明
MaxMessageHandle()

方法概要

限定符和类型	方法和说明
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.
int	attemptedBytesRead() Get how many bytes the read operation will (or did) attempt to read.
void	attemptedBytesRead(int bytes) Set how many bytes the read operation will (or did) attempt to read.
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.
void	incMessagesRead(int amt) Increment the number of messages that have been read for the current read loop.
int	lastBytesRead() Get the amount of bytes for the previous read operation.
void	lastBytesRead(int bytes) Set the bytes that have been read for the last read operation.
void	readComplete() The read has completed.
void	reset(ChannelConfig config) Only ChannelConfig.getMaxMessagesPerRead() is used.
protected int	totalBytesRead()

从类继承的方法 java.lang.Object

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

从接口继承的方法 io.netty.channel.RecvByteBufAllocator.Handle

guess

构造器详细资料

MaxMessageHandle

public MaxMessageHandle()

方法详细资料

reset

public void reset(ChannelConfig config)

Only ChannelConfig.getMaxMessagesPerRead() is used.

指定者:

reset 在接口中 RecvByteBufAllocator.Handle

参数:

config - The channel configuration which may impact this object's behavior.

allocate

public ByteBuf allocate(ByteBufAllocator alloc)

从接口复制的说明: 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.

指定者:

allocate 在接口中 RecvByteBufAllocator.Handle

incMessagesRead

public final void incMessagesRead(int amt)

从接口复制的说明: RecvByteBufAllocator.Handle

Increment the number of messages that have been read for the current read loop.

指定者:

incMessagesRead 在接口中 RecvByteBufAllocator.Handle

参数:

amt - The amount to increment by.

lastBytesRead

public void lastBytesRead(int bytes)

从接口复制的说明: RecvByteBufAllocator.Handle

Set the bytes that have been read for the last read operation. This may be used to increment the number of bytes that have been read.

指定者:

lastBytesRead 在接口中 RecvByteBufAllocator.Handle

参数:

bytes - The number of bytes from the previous read operation. This may be negative if an read error occurs. If a negative value is seen it is expected to be return on the next call to RecvByteBufAllocator.Handle.lastBytesRead(). A negative value will signal a termination condition enforced externally to this class and is not required to be enforced in RecvByteBufAllocator.Handle.continueReading().

lastBytesRead

public final int lastBytesRead()

从接口复制的说明: RecvByteBufAllocator.Handle

Get the amount of bytes for the previous read operation.

指定者:

lastBytesRead 在接口中 RecvByteBufAllocator.Handle

返回:

The amount of bytes for the previous read operation.

continueReading

public boolean continueReading()

从接口复制的说明: RecvByteBufAllocator.Handle

Determine if the current read loop should continue.

指定者:

continueReading 在接口中 RecvByteBufAllocator.Handle

返回:

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

continueReading

public boolean continueReading(UncheckedBooleanSupplier maybeMoreDataSupplier)

从接口复制的说明: RecvByteBufAllocator.ExtendedHandle

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

指定者:

continueReading 在接口中 RecvByteBufAllocator.ExtendedHandle

参数:

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

readComplete

public void readComplete()

从接口复制的说明: RecvByteBufAllocator.Handle

The read has completed.

指定者:

readComplete 在接口中 RecvByteBufAllocator.Handle

attemptedBytesRead

public int attemptedBytesRead()

从接口复制的说明: RecvByteBufAllocator.Handle

Get how many bytes the read operation will (or did) attempt to read.

指定者:

attemptedBytesRead 在接口中 RecvByteBufAllocator.Handle

返回:

How many bytes the read operation will (or did) attempt to read.

attemptedBytesRead

public void attemptedBytesRead(int bytes)

从接口复制的说明: RecvByteBufAllocator.Handle

Set how many bytes the read operation will (or did) attempt to read.

指定者:

attemptedBytesRead 在接口中 RecvByteBufAllocator.Handle

参数:

bytes - How many bytes the read operation will (or did) attempt to read.

totalBytesRead

protected final int totalBytesRead()