issueStreamError() — netty Function Reference

Architecture documentation for the issueStreamError() function in SpdySessionHandler.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 1

Entity Profile

Buffer→ Allocators→ issueStreamError() — netty Function Reference

Dependency Diagram

graph TD
  523c4082_b738_2187_2ebe_17c60a486843["issueStreamError()"]
  1fb79984_fd8e_cecc_3934_20ed3529f561["SpdySessionHandler"]
  523c4082_b738_2187_2ebe_17c60a486843 -->|defined in| 1fb79984_fd8e_cecc_3934_20ed3529f561
  d2ae1d21_cf0c_c4d0_e046_efc746940057["channelRead()"]
  d2ae1d21_cf0c_c4d0_e046_efc746940057 -->|calls| 523c4082_b738_2187_2ebe_17c60a486843
  9259efc1_c40e_efc0_2d75_ce800778ec12["removeStream()"]
  523c4082_b738_2187_2ebe_17c60a486843 -->|calls| 9259efc1_c40e_efc0_2d75_ce800778ec12
  style 523c4082_b738_2187_2ebe_17c60a486843 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http/src/main/java/io/netty/handler/codec/spdy/SpdySessionHandler.java lines 668–678

    private void issueStreamError(ChannelHandlerContext ctx, int streamId, SpdyStreamStatus status) {
        boolean fireChannelRead = !spdySession.isRemoteSideClosed(streamId);
        ChannelPromise promise = ctx.newPromise();
        removeStream(streamId, promise);

        SpdyRstStreamFrame spdyRstStreamFrame = new DefaultSpdyRstStreamFrame(streamId, status);
        ctx.writeAndFlush(spdyRstStreamFrame, promise);
        if (fireChannelRead) {
            ctx.fireChannelRead(spdyRstStreamFrame);
        }
    }