Improve AbstractResponseBodyProcessor.onNext(..)

If the provided DataBuffer is empty then request the next DataBuffer.
snailbinich · Oct 14, 2016 · ced6559 · ced6559
1 parent fada5ae
commit ced6559
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...src/main/java/org/springframework/http/server/reactive/AbstractResponseBodyProcessor.java b/...src/main/java/org/springframework/http/server/reactive/AbstractResponseBodyProcessor.java
@@ -218,7 +218,10 @@ public void onSubscribe(AbstractResponseBodyProcessor processor, Subscription su
 
 			@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();
 				}