newOutboundStream() — netty Function Reference

Architecture documentation for the newOutboundStream() function in Http2FrameCodecTest.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ newOutboundStream() — netty Function Reference

Dependency Diagram

graph TD
  6e4c2a23_359c_cdb9_e174_672d21517e19["newOutboundStream()"]
  71f17950_8fc4_c3e9_2e13_384d1ac7ea2c["Http2FrameCodecTest"]
  6e4c2a23_359c_cdb9_e174_672d21517e19 -->|defined in| 71f17950_8fc4_c3e9_2e13_384d1ac7ea2c
  style 6e4c2a23_359c_cdb9_e174_672d21517e19 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/Http2FrameCodecTest.java lines 653–675

    @Test
    @Timeout(value = 5000, unit = TimeUnit.MILLISECONDS)
    public void newOutboundStream() {
        final Http2FrameStream stream = frameCodec.newStream();

        assertNotNull(stream);
        assertFalse(isStreamIdValid(stream.id()));

        final Promise<Void> listenerExecuted = new DefaultPromise<Void>(GlobalEventExecutor.INSTANCE);

        channel.writeAndFlush(new DefaultHttp2HeadersFrame(new DefaultHttp2Headers(), false).stream(stream))
               .addListener(future -> {
                   assertTrue(future.isSuccess());
                   assertTrue(isStreamIdValid(stream.id()));
                   listenerExecuted.setSuccess(null);
               });
        ByteBuf data = Unpooled.buffer().writeZero(100);
        ChannelFuture f = channel.writeAndFlush(new DefaultHttp2DataFrame(data).stream(stream));
        assertTrue(f.isSuccess());

        listenerExecuted.syncUninterruptibly();
        assertTrue(listenerExecuted.isSuccess());
    }