Package io.netty.incubator.channel.uring
Class IOUringRecvByteAllocatorHandle
- java.lang.Object
-
- io.netty.channel.RecvByteBufAllocator.DelegatingHandle
-
- io.netty.incubator.channel.uring.IOUringRecvByteAllocatorHandle
-
- All Implemented Interfaces:
io.netty.channel.RecvByteBufAllocator.ExtendedHandle
,io.netty.channel.RecvByteBufAllocator.Handle
final class IOUringRecvByteAllocatorHandle extends io.netty.channel.RecvByteBufAllocator.DelegatingHandle implements io.netty.channel.RecvByteBufAllocator.ExtendedHandle
-
-
Field Summary
Fields Modifier and Type Field Description private io.netty.channel.unix.PreferredDirectByteBufAllocator
preferredDirectByteBufAllocator
private boolean
rdHupReceived
-
Constructor Summary
Constructors Constructor Description IOUringRecvByteAllocatorHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.netty.buffer.ByteBuf
allocate(io.netty.buffer.ByteBufAllocator alloc)
boolean
continueReading()
boolean
continueReading(io.netty.util.UncheckedBooleanSupplier maybeMoreDataSupplier)
(package private) void
rdHupReceived()
-
Methods inherited from class io.netty.channel.RecvByteBufAllocator.DelegatingHandle
attemptedBytesRead, attemptedBytesRead, delegate, guess, incMessagesRead, lastBytesRead, lastBytesRead, readComplete, reset
-
-
-
-
Method Detail
-
rdHupReceived
void rdHupReceived()
-
allocate
public io.netty.buffer.ByteBuf allocate(io.netty.buffer.ByteBufAllocator alloc)
- Specified by:
allocate
in interfaceio.netty.channel.RecvByteBufAllocator.Handle
- Overrides:
allocate
in classio.netty.channel.RecvByteBufAllocator.DelegatingHandle
-
continueReading
public boolean continueReading()
- Specified by:
continueReading
in interfaceio.netty.channel.RecvByteBufAllocator.Handle
- Overrides:
continueReading
in classio.netty.channel.RecvByteBufAllocator.DelegatingHandle
-
continueReading
public boolean continueReading(io.netty.util.UncheckedBooleanSupplier maybeMoreDataSupplier)
- Specified by:
continueReading
in interfaceio.netty.channel.RecvByteBufAllocator.ExtendedHandle
-
-