Http3RequestStreamDecodeStateValidator Class — netty Architecture

Source Code

codec-http3/src/main/java/io/netty/handler/codec/http3/Http3RequestStreamDecodeStateValidator.java lines 28–62

final class Http3RequestStreamDecodeStateValidator extends ChannelInboundHandlerAdapter
        implements Http3RequestStreamCodecState {
    private State state = State.None;

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        if (!(msg instanceof Http3RequestStreamFrame)) {
            super.channelRead(ctx, msg);
            return;
        }
        final Http3RequestStreamFrame frame = (Http3RequestStreamFrame) msg;
        final State nextState = evaluateFrame(state, frame);
        if (nextState == null) {
            frameTypeUnexpected(ctx, msg);
            return;
        }
        state = nextState;
        super.channelRead(ctx, msg);
    }

    @Override
    public boolean started() {
        return isStreamStarted(state);
    }

    @Override
    public boolean receivedFinalHeaders() {
        return isFinalHeadersReceived(state);
    }

    @Override
    public boolean terminated() {
        return isTrailersReceived(state);
    }
}