continueReading() — netty Function Reference

Architecture documentation for the continueReading() function in NioDatagramChannel.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ continueReading() — netty Function Reference

Dependency Diagram

graph TD
  87f93a67_916c_5096_ebb0_7efb924e9f74["continueReading()"]
  62bb7cb5_86a2_a73b_659d_4f8936fbd7b8["NioDatagramChannel"]
  87f93a67_916c_5096_ebb0_7efb924e9f74 -->|defined in| 62bb7cb5_86a2_a73b_659d_4f8936fbd7b8
  style 87f93a67_916c_5096_ebb0_7efb924e9f74 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannel.java lines 618–627

    @Override
    protected boolean continueReading(RecvByteBufAllocator.Handle allocHandle) {
        if (allocHandle instanceof RecvByteBufAllocator.ExtendedHandle) {
            // We use the TRUE_SUPPLIER as it is also ok to read less then what we did try to read (as long
            // as we read anything).
            return ((RecvByteBufAllocator.ExtendedHandle) allocHandle)
                    .continueReading(UncheckedBooleanSupplier.TRUE_SUPPLIER);
        }
        return allocHandle.continueReading();
    }