netty Architecture Docs
Home / Function/ testCreateStreamViaBootstrap() — netty Function Reference

testCreateStreamViaBootstrap() — netty Function Reference

Architecture documentation for the testCreateStreamViaBootstrap() function in QuicStreamChannelCreationTest.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Dependency Diagram

graph TD
  ef305828_94d3_348b_b022_65ae5f123fc3["testCreateStreamViaBootstrap()"]
  c27c449e_05b7_6104_9f32_ebabb5202beb["QuicStreamChannelCreationTest"]
  ef305828_94d3_348b_b022_65ae5f123fc3 -->|defined in| c27c449e_05b7_6104_9f32_ebabb5202beb
  af7f2278_621b_79cf_a6ec_07f9a064ac11["assertQuicStreamChannel()"]
  ef305828_94d3_348b_b022_65ae5f123fc3 -->|calls| af7f2278_621b_79cf_a6ec_07f9a064ac11
  style ef305828_94d3_348b_b022_65ae5f123fc3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicStreamChannelCreationTest.java lines 81–125

    @ParameterizedTest
    @MethodSource("newSslTaskExecutors")
    public void testCreateStreamViaBootstrap(Executor executor) throws Throwable {
        QuicChannelValidationHandler serverHandler = new QuicChannelValidationHandler();
        Channel server = QuicTestUtils.newServer(executor, serverHandler,
                new ChannelInboundHandlerAdapter());
        InetSocketAddress address = (InetSocketAddress) server.localAddress();
        Channel channel = QuicTestUtils.newClient(executor);
        QuicChannelValidationHandler clientHandler = new QuicChannelValidationHandler();

        try {
            QuicChannel quicChannel = QuicTestUtils.newQuicChannelBootstrap(channel)
                    .handler(clientHandler)
                    .streamHandler(new ChannelInboundHandlerAdapter())
                    .remoteAddress(address)
                    .connect()
                    .get();
            CountDownLatch latch = new CountDownLatch(1);
            QuicStreamChannel stream = quicChannel.newStreamBootstrap()
                    .type(QuicStreamType.UNIDIRECTIONAL)
                    .attr(ATTRIBUTE_KEY, ATTRIBUTE_VALUE)
                    .option(ChannelOption.AUTO_READ,  Boolean.FALSE)
                    .handler(new ChannelInboundHandlerAdapter() {
                        @Override
                        public void channelRegistered(ChannelHandlerContext ctx) {
                            assertQuicStreamChannel((QuicStreamChannel) ctx.channel(),
                                    QuicStreamType.UNIDIRECTIONAL, Boolean.FALSE, ATTRIBUTE_VALUE);
                            latch.countDown();
                        }
                    }).create().sync().get();
            assertQuicStreamChannel(stream, QuicStreamType.UNIDIRECTIONAL, Boolean.FALSE, ATTRIBUTE_VALUE);
            latch.await();
            stream.close().sync();
            quicChannel.close().sync();

            serverHandler.assertState();
            clientHandler.assertState();
        } finally {
            server.close().syncUninterruptibly();
            // Close the parent Datagram channel as well.
            channel.close().sync();

            shutdown(executor);
        }
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does testCreateStreamViaBootstrap() do?
testCreateStreamViaBootstrap() is a function in the netty codebase, defined in codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicStreamChannelCreationTest.java.
Where is testCreateStreamViaBootstrap() defined?
testCreateStreamViaBootstrap() is defined in codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicStreamChannelCreationTest.java at line 81.
What does testCreateStreamViaBootstrap() call?
testCreateStreamViaBootstrap() calls 1 function(s): assertQuicStreamChannel.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free