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 Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -142,12 +142,12 @@ void onStreamWritabilityChanged(Http2Stream s) {
142142 void onStreamClosed (Http2Stream s ) {
143143 VertxHttp2Stream stream = s .getProperty (streamKey );
144144 if (stream != null ) {
145- // boolean active = chctx.channel().isActive();
146- // if (goAwayStatus != null) {
147- // stream.onException(new HttpClosedException(goAwayStatus));
148- // } else if (!active) {
149- // stream.onException(HttpUtils.STREAM_CLOSED_EXCEPTION);
150- // }
145+ boolean active = chctx .channel ().isActive ();
146+ if (goAwayStatus != null ) {
147+ stream .onException (new HttpClosedException (goAwayStatus ));
148+ } else if (!active ) {
149+ stream .onException (HttpUtils .STREAM_CLOSED_EXCEPTION );
150+ }
151151 stream .onClose ();
152152 }
153153 }
You can’t perform that action at this time.
0 commit comments