windowUpdateShouldNotBeSentAfterStreamIsClosedForUnconsumedBytes() — netty Function Reference

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/DefaultHttp2LocalFlowControllerTest.java lines 171–191

    @Test
    public void windowUpdateShouldNotBeSentAfterStreamIsClosedForUnconsumedBytes() throws Http2Exception {
        int dataSize = (int) (DEFAULT_WINDOW_SIZE * DEFAULT_WINDOW_UPDATE_RATIO) + 1;

        // Don't set end-of-stream on the frame as we want to verify that we not return the unconsumed bytes in this
        // case once the stream was closed,
        receiveFlowControlledFrame(STREAM_ID, dataSize, 0, false);
        verifyWindowUpdateNotSent(CONNECTION_STREAM_ID);
        verifyWindowUpdateNotSent(STREAM_ID);

        // Close the stream
        Http2Stream stream = connection.stream(STREAM_ID);
        stream.close();
        assertEquals(State.CLOSED, stream.state());
        assertNull(connection.stream(STREAM_ID));

        // The window update for the connection should made it through but not the update for the already closed
        // stream
        verifyWindowUpdateSent(CONNECTION_STREAM_ID, dataSize);
        verifyWindowUpdateNotSent(STREAM_ID);
    }