sendRstStream() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ sendRstStream() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/Http2FrameCodecTest.java lines 297–317

    @Test
    public void sendRstStream() throws Exception {
        frameInboundWriter.writeInboundHeaders(3, request, 31, true);

        Http2Stream stream = frameCodec.connection().stream(3);
        assertNotNull(stream);
        assertEquals(State.HALF_CLOSED_REMOTE, stream.state());

        Http2HeadersFrame inboundHeaders = inboundHandler.readInbound();
        assertNotNull(inboundHeaders);
        assertTrue(inboundHeaders.isEndStream());

        Http2FrameStream stream2 = inboundHeaders.stream();
        assertNotNull(stream2);
        assertEquals(3, stream2.id());

        channel.writeOutbound(new DefaultHttp2ResetFrame(314 /* non-standard error */).stream(stream2));
        verify(frameWriter).writeRstStream(eqFrameCodecCtx(), eq(3), eq(314L), anyChannelPromise());
        assertEquals(State.CLOSED, stream.state());
        assertTrue(channel.isActive());
    }