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

testShutdownInputClosureCausesStreamStopped() — netty Function Reference

Architecture documentation for the testShutdownInputClosureCausesStreamStopped() function in QuicStreamShutdownTest.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Dependency Diagram

graph TD
  dcf12060_a684_6392_e406_d316f98f13cc["testShutdownInputClosureCausesStreamStopped()"]
  8f0deefd_ac73_09cd_1ee0_413b4ec84595["QuicStreamShutdownTest"]
  dcf12060_a684_6392_e406_d316f98f13cc -->|defined in| 8f0deefd_ac73_09cd_1ee0_413b4ec84595
  style dcf12060_a684_6392_e406_d316f98f13cc fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicStreamShutdownTest.java lines 42–85

    @ParameterizedTest
    @MethodSource("newSslTaskExecutors")
    public void testShutdownInputClosureCausesStreamStopped(Executor executor) throws Throwable {
        Channel server = null;
        Channel channel = null;
        CountDownLatch latch = new CountDownLatch(2);
        try {
            server = QuicTestUtils.newServer(executor, new ChannelInboundHandlerAdapter(),
                    new ChannelInboundHandlerAdapter() {
                        @Override
                        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
                            ChannelFutureListener futureListener = channelFuture -> {
                                Throwable cause = channelFuture.cause();
                                if (cause instanceof ChannelOutputShutdownException) {
                                    latch.countDown();
                                }
                            };
                            ByteBuf buffer = (ByteBuf) msg;
                            ctx.write(buffer.retainedDuplicate()).addListener(futureListener);
                            ctx.writeAndFlush(buffer).addListener(futureListener);
                        }
                    });
            channel = QuicTestUtils.newClient(executor);
            QuicChannel quicChannel = QuicTestUtils.newQuicChannelBootstrap(channel)
                    .handler(new ChannelInboundHandlerAdapter())
                    .streamHandler(new ChannelInboundHandlerAdapter())
                    .remoteAddress(server.localAddress())
                    .connect()
                    .get();

            QuicStreamChannel streamChannel = quicChannel.createStream(QuicStreamType.BIDIRECTIONAL,
                    new ChannelInboundHandlerAdapter()).sync().getNow();
            streamChannel.shutdownInput().sync();
            assertTrue(streamChannel.isInputShutdown());
            streamChannel.writeAndFlush(Unpooled.buffer().writeLong(8)).sync();

            latch.await();
        } finally {
            QuicTestUtils.closeIfNotNull(channel);
            QuicTestUtils.closeIfNotNull(server);

            shutdown(executor);
        }
    }

Domain

Subdomains

Defined In

Source

Frequently Asked Questions

What does testShutdownInputClosureCausesStreamStopped() do?
testShutdownInputClosureCausesStreamStopped() is a function in the netty codebase, defined in codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicStreamShutdownTest.java.
Where is testShutdownInputClosureCausesStreamStopped() defined?
testShutdownInputClosureCausesStreamStopped() is defined in codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicStreamShutdownTest.java at line 42.

Analyze Your Own Codebase

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

Try Supermodel Free