Module io.netty5.transport

Package io.netty5.channel

Class MaxMessagesReadHandleFactory.MaxMessageReadHandle

java.lang.Object

io.netty5.channel.MaxMessagesReadHandleFactory.MaxMessageReadHandle

All Implemented Interfaces:

ReadHandleFactory.ReadHandle

Enclosing class:

MaxMessagesReadHandleFactory

protected abstract static class MaxMessagesReadHandleFactory.MaxMessageReadHandle
extends Object
implements ReadHandleFactory.ReadHandle

Focuses on enforcing the maximum messages per read condition for lastRead(int, int, int).

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MaxMessageReadHandle(int maxMessagesPerRead)

Method Summary

Modifier and Type	Method	Description
boolean	lastRead(int attemptedBytesRead, int actualBytesRead, int numMessagesRead)	Notify the ReadHandleFactory.ReadHandle of the last read operation and its result.
void	readComplete()	Method that must be called once the read loop was completed.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty5.channel.ReadHandleFactory.ReadHandle

estimatedBufferCapacity

Constructor Detail

MaxMessageReadHandle

protected MaxMessageReadHandle(int maxMessagesPerRead)

Method Detail

lastRead

public boolean lastRead(int attemptedBytesRead,
                        int actualBytesRead,
                        int numMessagesRead)

Description copied from interface: ReadHandleFactory.ReadHandle

Notify the ReadHandleFactory.ReadHandle of the last read operation and its result.

Specified by:

lastRead in interface ReadHandleFactory.ReadHandle

Parameters:

attemptedBytesRead - The number of bytes the read operation did attempt to read.

actualBytesRead - The number of bytes from the previous read operation. This may be negative if a read error occurs.

numMessagesRead - The number of messages read.

Returns:

true if the read loop should continue reading, false otherwise.

readComplete

public void readComplete()

Description copied from interface: ReadHandleFactory.ReadHandle

Method that must be called once the read loop was completed.

Specified by:

readComplete in interface ReadHandleFactory.ReadHandle