diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteProcessor.java b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteProcessor.java index bc55d0052b..50a245dc30 100644 --- a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteProcessor.java +++ b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteProcessor.java @@ -162,7 +162,11 @@ public abstract class AbstractListenerWriteProcessor implements ProcessorThe default implementation is a no-op. + * @deprecated originally introduced for Undertow to stop write notifications + * when no data is available, but deprecated as of as of 5.0.6 since constant + * switching on every requested item causes a significant slowdown. */ + @Deprecated protected void writingPaused() { } @@ -271,6 +275,7 @@ public abstract class AbstractListenerWriteProcessor implements Processor void onWritePossible(AbstractListenerWriteProcessor processor) { if (processor.changeState(this, WRITING)) { diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/UndertowServerHttpResponse.java b/spring-web/src/main/java/org/springframework/http/server/reactive/UndertowServerHttpResponse.java index b00e338010..58aed42f29 100644 --- a/spring-web/src/main/java/org/springframework/http/server/reactive/UndertowServerHttpResponse.java +++ b/spring-web/src/main/java/org/springframework/http/server/reactive/UndertowServerHttpResponse.java @@ -217,11 +217,6 @@ class UndertowServerHttpResponse extends AbstractListenerServerHttpResponse impl return (dataBuffer.readableByteCount() == 0); } - @Override - protected void writingPaused() { - this.channel.suspendWrites(); - } - @Override protected void writingComplete() { this.channel.getWriteSetter().set(null);