From 975ee3bc8554847064aa1145a4331b4a3653f309 Mon Sep 17 00:00:00 2001
From: sp619r <sp619r@DTV-H66293.ITServices.sbc.com>
Date: Mon, 3 Apr 2017 21:02:58 -0700
Subject: [PATCH] BAEL-679 second draft

---
 .../java9/reactive/BaeldungBatchSubscriberImpl.java         | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

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
index 4c65cb35b6..46eee4883a 100644
--- 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 class BaeldungBatchSubscriberImpl<T> implements Subscriber<String> {
         // 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() {