Skip to content

Commit a3be006

Browse files
committed
Cancel on unavailable connection
1 parent 3b356ce commit a3be006

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

http/http-server-undertow/src/main/java/ru/tinkoff/kora/http/server/undertow/UndertowExchangeProcessor.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -405,13 +405,8 @@ public void onNext(ByteBuffer byteBuffer) {
405405
return;
406406
}
407407

408-
if (this.shutdownHandler.isShutdown()) {
409-
HttpResponseBodySubscriber.this.subscription.cancel();
410-
this.exchange.endExchange();
411-
return;
412-
}
413-
414408
if (!this.exchange.getConnection().isOpen()) {
409+
HttpResponseBodySubscriber.this.subscription.cancel();
415410
return;
416411
}
417412

0 commit comments

Comments
 (0)