File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed
vertx-core/src/main/java/io/vertx/core/http/impl/http2/codec Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -147,12 +147,12 @@ void onStreamWritabilityChanged(Http2Stream s) {
147147 void onStreamClosed (Http2Stream s ) {
148148 Http2StreamBase stream = s .getProperty (streamKey );
149149 if (stream != null ) {
150- // boolean active = chctx.channel().isActive();
151- // if (goAwayStatus != null) {
152- // stream.onException(new HttpClosedException(goAwayStatus));
153- // } else if (!active) {
154- // stream.onException(HttpUtils.STREAM_CLOSED_EXCEPTION);
155- // }
150+ boolean active = chctx .channel ().isActive ();
151+ if (goAwayStatus != null ) {
152+ stream .onException (new HttpClosedException (goAwayStatus ));
153+ } else if (!active ) {
154+ stream .onException (HttpUtils .STREAM_CLOSED_EXCEPTION );
155+ }
156156 stream .onClose ();
157157 }
158158 }
You can’t perform that action at this time.
0 commit comments