BAEL-679 second draft

sp619r · sp619r · commit 975ee3bc8554 · 2017-04-03T21:02:58.000-07:00
diff --git a/core-java-9/src/main/java/com/baeldung/java9/reactive/BaeldungBatchSubscriberImpl.java b/core-java-9/src/main/java/com/baeldung/java9/reactive/BaeldungBatchSubscriberImpl.java
@@ -43,11 +43,9 @@ public void onNext(String item) {
         // if buffer is full, process the items.
         if (buffer.size() >= BUFFER_SIZE) {
             processBuffer();
-            subscription.request(BUFFER_SIZE);
-        } else if(buffer.size() == 0) {
-            // If buffer empty, request more items.
-            subscription.request(BUFFER_SIZE);
         }
+        //request more items.
+        subscription.request(1);
     }
 
     private void processBuffer() {

Original file line number	Diff line number	Diff line change
`@@ -43,11 +43,9 @@ public void onNext(String item) {`
`43`	`43`	`// if buffer is full, process the items.`
`44`	`44`	`if (buffer.size() >= BUFFER_SIZE) {`
`45`	`45`	`processBuffer();`
`46`		`- subscription.request(BUFFER_SIZE);`
`47`		`- } else if(buffer.size() == 0) {`
`48`		`- // If buffer empty, request more items.`
`49`		`- subscription.request(BUFFER_SIZE);`
`50`	`46`	`}`
	`47`	`+ //request more items.`
	`48`	`+ subscription.request(1);`
`51`	`49`	`}`
`52`	`50`
`53`	`51`	`private void processBuffer() {`