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

sendingGoAwayShouldNotFailStreams() — netty Function Reference

Architecture documentation for the sendingGoAwayShouldNotFailStreams() function in StreamBufferingEncoderTest.java from the netty codebase.

Function java Buffer Allocators calls 2

Entity Profile

Dependency Diagram

graph TD
  569bbfdb_1483_c5d9_1ce7_fcd616d9c72d["sendingGoAwayShouldNotFailStreams()"]
  b13b21e9_41cb_8feb_3534_f953823cad07["StreamBufferingEncoderTest"]
  569bbfdb_1483_c5d9_1ce7_fcd616d9c72d -->|defined in| b13b21e9_41cb_8feb_3534_f953823cad07
  f0871f47_b22a_42a3_326b_2bb017254453["setMaxConcurrentStreams()"]
  569bbfdb_1483_c5d9_1ce7_fcd616d9c72d -->|calls| f0871f47_b22a_42a3_326b_2bb017254453
  5429b381_1fa6_b38b_0c55_cfca3e18c639["successAnswer()"]
  569bbfdb_1483_c5d9_1ce7_fcd616d9c72d -->|calls| 5429b381_1fa6_b38b_0c55_cfca3e18c639
  style 569bbfdb_1483_c5d9_1ce7_fcd616d9c72d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/StreamBufferingEncoderTest.java lines 284–308

    @Test
    public void sendingGoAwayShouldNotFailStreams() {
        setMaxConcurrentStreams(1);

        when(writer.writeHeaders(any(ChannelHandlerContext.class), anyInt(), any(Http2Headers.class), anyInt(),
              anyBoolean(), any(ChannelPromise.class))).thenAnswer(successAnswer());
        when(writer.writeHeaders(any(ChannelHandlerContext.class), anyInt(), any(Http2Headers.class), anyInt(),
              anyShort(), anyBoolean(), anyInt(), anyBoolean(), any(ChannelPromise.class))).thenAnswer(successAnswer());

        ChannelFuture f1 = encoderWriteHeaders(3, newPromise());
        assertEquals(0, encoder.numBufferedStreams());
        ChannelFuture f2 = encoderWriteHeaders(5, newPromise());
        assertEquals(1, encoder.numBufferedStreams());
        ChannelFuture f3 = encoderWriteHeaders(7, newPromise());
        assertEquals(2, encoder.numBufferedStreams());

        ByteBuf empty = Unpooled.buffer(0);
        encoder.writeGoAway(ctx, 3, CANCEL.code(), empty, newPromise());

        assertEquals(1, connection.numActiveStreams());
        assertEquals(2, encoder.numBufferedStreams());
        assertFalse(f1.isDone());
        assertFalse(f2.isDone());
        assertFalse(f3.isDone());
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does sendingGoAwayShouldNotFailStreams() do?
sendingGoAwayShouldNotFailStreams() is a function in the netty codebase, defined in codec-http2/src/test/java/io/netty/handler/codec/http2/StreamBufferingEncoderTest.java.
Where is sendingGoAwayShouldNotFailStreams() defined?
sendingGoAwayShouldNotFailStreams() is defined in codec-http2/src/test/java/io/netty/handler/codec/http2/StreamBufferingEncoderTest.java at line 284.
What does sendingGoAwayShouldNotFailStreams() call?
sendingGoAwayShouldNotFailStreams() calls 2 function(s): setMaxConcurrentStreams, successAnswer.

Analyze Your Own Codebase

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

Try Supermodel Free