diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/ChannelSendOperator.java b/spring-web/src/main/java/org/springframework/http/server/reactive/ChannelSendOperator.java index dec69f86675..bba714f60a9 100644 --- a/spring-web/src/main/java/org/springframework/http/server/reactive/ChannelSendOperator.java +++ b/spring-web/src/main/java/org/springframework/http/server/reactive/ChannelSendOperator.java @@ -229,9 +229,9 @@ public class ChannelSendOperator extends Mono implements Scannable { if (n == 0) { return; } + s.request(n); } } - s.request(n); } private boolean emitCachedSignals() {