setUp() — netty Function Reference

Source Code

codec-http3/src/test/java/io/netty/handler/codec/http3/Http3FrameCodecTest.java lines 96–135

    private void setUp(int maxBlockedStreams, boolean delayQpackStreams) throws Exception {
        parent = new EmbeddedQuicChannel(true);
        qpackAttributes = new QpackAttributes(parent, false);
        Http3.setQpackAttributes(parent, qpackAttributes);
        final Http3SettingsFrame settings = new DefaultHttp3SettingsFrame();
        maxTableCapacity = 1024L;
        settings.put(Http3SettingsFrame.HTTP3_SETTINGS_QPACK_MAX_TABLE_CAPACITY, maxTableCapacity);
        settings.put(Http3SettingsFrame.HTTP3_SETTINGS_QPACK_BLOCKED_STREAMS, (long) maxBlockedStreams);
        decoder = new QpackDecoder(maxTableCapacity, maxBlockedStreams);
        decoder.setDynamicTableCapacity(maxTableCapacity);
        qpackEncoderHandler = new QpackEncoderHandler(maxTableCapacity, decoder);
        encoderStream = (EmbeddedQuicStreamChannel) parent.createStream(QuicStreamType.UNIDIRECTIONAL,
                new ChannelOutboundHandlerAdapter()).get();
        encoder = new QpackEncoder();
        qpackDecoderHandler = new QpackDecoderHandler(encoder);
        decoderStream = (EmbeddedQuicStreamChannel) parent.createStream(QuicStreamType.UNIDIRECTIONAL,
                new ChannelOutboundHandlerAdapter()).get();
        qpackAttributes.whenEncoderStreamAvailable(future -> {
            if (future.isSuccess()) {
                encoder.configureDynamicTable(qpackAttributes, maxTableCapacity, maxBlockedStreams);
            }
        });
        if (!delayQpackStreams) {
            setQpackStreams();
        }
        codecChannel = (EmbeddedQuicStreamChannel) parent.createStream(QuicStreamType.BIDIRECTIONAL,
                new ChannelInitializer<QuicStreamChannel>() {
                    @Override
                    protected void initChannel(QuicStreamChannel ch) {
                        Http3RequestStreamEncodeStateValidator encStateValidator =
                                new Http3RequestStreamEncodeStateValidator();
                        Http3RequestStreamDecodeStateValidator decStateValidator =
                                new Http3RequestStreamDecodeStateValidator();
                        ch.pipeline().addLast(new Http3FrameCodec(Http3FrameTypeValidator.NO_VALIDATION, decoder,
                                MAX_HEADER_SIZE, encoder, encStateValidator, decStateValidator, (id, v) -> false));
                        ch.pipeline().addLast(encStateValidator);
                        ch.pipeline().addLast(decStateValidator);
                    }
                }).get();
    }