AbstractHttp2StreamChannel() — netty Function Reference

Source Code

codec-http2/src/main/java/io/netty/handler/codec/http2/AbstractHttp2StreamChannel.java lines 215–253

    AbstractHttp2StreamChannel(DefaultHttp2FrameStream stream, int id, ChannelHandler inboundHandler) {
        this.stream = stream;
        stream.attachment = this;
        pipeline = new DefaultChannelPipeline(this) {
            @Override
            protected void incrementPendingOutboundBytes(long size) {
                AbstractHttp2StreamChannel.this.incrementPendingOutboundBytes(size, true);
            }

            @Override
            protected void decrementPendingOutboundBytes(long size) {
                AbstractHttp2StreamChannel.this.decrementPendingOutboundBytes(size, true);
            }

            @Override
            protected void onUnhandledInboundException(Throwable cause) {
                // Ensure we use the correct Http2Error to close the channel.
                if (cause instanceof Http2FrameStreamException) {
                    closeWithError(((Http2FrameStreamException) cause).error());
                    return;
                } else {
                    Http2Exception exception = Http2CodecUtil.getEmbeddedHttp2Exception(cause);
                    if (exception != null) {
                        closeWithError(exception.error());
                        return;
                    }
                }
                super.onUnhandledInboundException(cause);
            }
        };

        closePromise = pipeline.newPromise();
        channelId = new Http2StreamChannelId(parent().id(), id);

        if (inboundHandler != null) {
            // Add the handler to the pipeline now that we are registered.
            pipeline.addLast(inboundHandler);
        }
    }