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

creatingWritingReadingAndClosingOutboundStreamShouldWork() — netty Function Reference

Architecture documentation for the creatingWritingReadingAndClosingOutboundStreamShouldWork() function in Http2MultiplexTest.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Dependency Diagram

graph TD
  b7d2f8c1_4fbb_be88_1758_9d7a20f75a17["creatingWritingReadingAndClosingOutboundStreamShouldWork()"]
  4745ff96_ed57_3bd8_9861_4b786d0b6e09["Http2MultiplexTest"]
  b7d2f8c1_4fbb_be88_1758_9d7a20f75a17 -->|defined in| 4745ff96_ed57_3bd8_9861_4b786d0b6e09
  22928953_49fc_cbc5_c75c_f236ce1e1fc7["eqStreamId()"]
  b7d2f8c1_4fbb_be88_1758_9d7a20f75a17 -->|calls| 22928953_49fc_cbc5_c75c_f236ce1e1fc7
  style b7d2f8c1_4fbb_be88_1758_9d7a20f75a17 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/Http2MultiplexTest.java lines 910–939

    @Test
    public void creatingWritingReadingAndClosingOutboundStreamShouldWork() {
        LastInboundHandler inboundHandler = new LastInboundHandler();
        Http2StreamChannel childChannel = newOutboundStream(inboundHandler);
        assertTrue(childChannel.isActive());
        assertTrue(inboundHandler.isChannelActive());

        // Write to the child channel
        Http2Headers headers = new DefaultHttp2Headers().scheme("https").method("GET").path("/foo.txt");
        childChannel.writeAndFlush(new DefaultHttp2HeadersFrame(headers));

        // Read from the child channel
        frameInboundWriter.writeInboundHeaders(childChannel.stream().id(), headers, 0, false);

        Http2HeadersFrame headersFrame = inboundHandler.readInbound();
        assertNotNull(headersFrame);
        assertEquals(headers, headersFrame.headers());

        // Close the child channel.
        childChannel.close();

        parentChannel.runPendingTasks();
        // An active outbound stream should emit a RST_STREAM frame.
        verify(frameWriter).writeRstStream(eqCodecCtx(), eqStreamId(childChannel),
                anyLong(), anyChannelPromise());

        assertFalse(childChannel.isOpen());
        assertFalse(childChannel.isActive());
        assertFalse(inboundHandler.isChannelActive());
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does creatingWritingReadingAndClosingOutboundStreamShouldWork() do?
creatingWritingReadingAndClosingOutboundStreamShouldWork() is a function in the netty codebase, defined in codec-http2/src/test/java/io/netty/handler/codec/http2/Http2MultiplexTest.java.
Where is creatingWritingReadingAndClosingOutboundStreamShouldWork() defined?
creatingWritingReadingAndClosingOutboundStreamShouldWork() is defined in codec-http2/src/test/java/io/netty/handler/codec/http2/Http2MultiplexTest.java at line 910.
What does creatingWritingReadingAndClosingOutboundStreamShouldWork() call?
creatingWritingReadingAndClosingOutboundStreamShouldWork() calls 1 function(s): eqStreamId.

Analyze Your Own Codebase

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

Try Supermodel Free