From ced65599413410be71b81ad0fb420d6be3013fc3 Mon Sep 17 00:00:00 2001
From: Violeta Georgieva <vgeorgieva@pivotal.io>
Date: Fri, 14 Oct 2016 23:26:17 +0300
Subject: [PATCH] Improve AbstractResponseBodyProcessor.onNext(..)

If the provided DataBuffer is empty then request the next DataBuffer.
---
 .../http/server/reactive/AbstractResponseBodyProcessor.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractResponseBodyProcessor.java b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractResponseBodyProcessor.java
index 0276ba3c227..d6067383927 100644
--- a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractResponseBodyProcessor.java
+++ b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractResponseBodyProcessor.java
@@ -218,7 +218,10 @@ abstract class AbstractResponseBodyProcessor implements Processor<DataBuffer, Vo
 
 			@Override
 			public void onNext(AbstractResponseBodyProcessor processor, DataBuffer dataBuffer) {
-				if (processor.changeState(this, RECEIVED)) {
+				if (dataBuffer.readableByteCount() == 0) {
+					processor.subscription.request(1);
+				}
+				else if (processor.changeState(this, RECEIVED)) {
 					processor.receiveBuffer(dataBuffer);
 					processor.writeIfPossible();
 				}