Class 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
    • 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
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface io.netty.channel.RecvByteBufAllocator.Handle

        attemptedBytesRead, attemptedBytesRead, guess, incMessagesRead, lastBytesRead, lastBytesRead, readComplete, reset
    • Field Detail

      • preferredDirectByteBufAllocator

        private final io.netty.channel.unix.PreferredDirectByteBufAllocator preferredDirectByteBufAllocator
      • rdHupReceived

        private boolean rdHupReceived
    • Constructor Detail

      • IOUringRecvByteAllocatorHandle

        IOUringRecvByteAllocatorHandle​(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)
    • Method Detail

      • rdHupReceived

        void rdHupReceived()
      • allocate

        public io.netty.buffer.ByteBuf allocate​(io.netty.buffer.ByteBufAllocator alloc)
        Specified by:
        allocate in interface io.netty.channel.RecvByteBufAllocator.Handle
        Overrides:
        allocate in class io.netty.channel.RecvByteBufAllocator.DelegatingHandle
      • continueReading

        public boolean continueReading()
        Specified by:
        continueReading in interface io.netty.channel.RecvByteBufAllocator.Handle
        Overrides:
        continueReading in class io.netty.channel.RecvByteBufAllocator.DelegatingHandle
      • continueReading

        public boolean continueReading​(io.netty.util.UncheckedBooleanSupplier maybeMoreDataSupplier)
        Specified by:
        continueReading in interface io.netty.channel.RecvByteBufAllocator.ExtendedHandle