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

queuedPayloadsReceiveErrorOnStreamClose() — netty Function Reference

Architecture documentation for the queuedPayloadsReceiveErrorOnStreamClose() function in DefaultHttp2RemoteFlowControllerTest.java from the netty codebase.

Function java Buffer Allocators calls 4

Entity Profile

Dependency Diagram

graph TD
  5be33bbd_ea57_0bc5_f862_e6ea4b476f8d["queuedPayloadsReceiveErrorOnStreamClose()"]
  f8fd7697_92d4_6455_4dd8_09a33ac81a6f["DefaultHttp2RemoteFlowControllerTest"]
  5be33bbd_ea57_0bc5_f862_e6ea4b476f8d -->|defined in| f8fd7697_92d4_6455_4dd8_09a33ac81a6f
  136071dd_c92e_5482_7cb2_c1ba0769c1ab["FakeFlowControlled()"]
  5be33bbd_ea57_0bc5_f862_e6ea4b476f8d -->|calls| 136071dd_c92e_5482_7cb2_c1ba0769c1ab
  85ffafbd_47aa_f4f5_fd02_71f26d692e10["sendData()"]
  5be33bbd_ea57_0bc5_f862_e6ea4b476f8d -->|calls| 85ffafbd_47aa_f4f5_fd02_71f26d692e10
  4d627b61_f0ea_0927_043f_7bfb246d71d1["assertNotWritten()"]
  5be33bbd_ea57_0bc5_f862_e6ea4b476f8d -->|calls| 4d627b61_f0ea_0927_043f_7bfb246d71d1
  d35164e2_8346_f5f5_f90a_f92c38f3329a["assertError()"]
  5be33bbd_ea57_0bc5_f862_e6ea4b476f8d -->|calls| d35164e2_8346_f5f5_f90a_f92c38f3329a
  style 5be33bbd_ea57_0bc5_f862_e6ea4b476f8d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/DefaultHttp2RemoteFlowControllerTest.java lines 244–264

    @Test
    public void queuedPayloadsReceiveErrorOnStreamClose() throws Http2Exception {
        controller.initialWindowSize(0);
        verify(listener, times(1)).writabilityChanged(stream(STREAM_A));
        assertFalse(controller.isWritable(stream(STREAM_A)));
        reset(listener);

        FakeFlowControlled data = new FakeFlowControlled(15);
        FakeFlowControlled moreData = new FakeFlowControlled(0);
        sendData(STREAM_A, data);
        controller.writePendingBytes();
        data.assertNotWritten();
        sendData(STREAM_A, moreData);
        controller.writePendingBytes();
        moreData.assertNotWritten();

        connection.stream(STREAM_A).close();
        data.assertError(Http2Error.STREAM_CLOSED);
        moreData.assertError(Http2Error.STREAM_CLOSED);
        verifyNoInteractions(listener);
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does queuedPayloadsReceiveErrorOnStreamClose() do?
queuedPayloadsReceiveErrorOnStreamClose() is a function in the netty codebase, defined in codec-http2/src/test/java/io/netty/handler/codec/http2/DefaultHttp2RemoteFlowControllerTest.java.
Where is queuedPayloadsReceiveErrorOnStreamClose() defined?
queuedPayloadsReceiveErrorOnStreamClose() is defined in codec-http2/src/test/java/io/netty/handler/codec/http2/DefaultHttp2RemoteFlowControllerTest.java at line 244.
What does queuedPayloadsReceiveErrorOnStreamClose() call?
queuedPayloadsReceiveErrorOnStreamClose() calls 4 function(s): FakeFlowControlled, assertError, assertNotWritten, sendData.

Analyze Your Own Codebase

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

Try Supermodel Free