Package io.netty.incubator.channel.uring

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