From 89a5c857acbc3d816fd7e5cf81a94475a812be64 Mon Sep 17 00:00:00 2001
From: Rossen Stoyanchev <rstoyanchev@pivotal.io>
Date: Wed, 12 Jul 2017 12:40:51 +0200
Subject: [PATCH] Fix recently intorduced bug in ChannelSendOperator

WriteBarrier acts as Subscription to both completionSubscriber and
writeSubscriber so the request method needs to be careful not to
pass on the request outside of readyToWrite or writeSubscriber checks.
---
 .../http/server/reactive/ChannelSendOperator.java               | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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<T> extends Mono<Void> implements Scannable {
 					if (n == 0) {
 						return;
 					}
+					s.request(n);
 				}
 			}
-			s.request(n);
 		}
 
 		private boolean emitCachedSignals() {