diff --git a/core-java-modules/core-java-streams-7/src/main/java/com/baeldung/streams/gatherer/SlidingWindowGatherer.java b/core-java-modules/core-java-streams-7/src/main/java/com/baeldung/streams/gatherer/SlidingWindowGatherer.java index 2d302ac42bf7..713d88e0e2a1 100644 --- a/core-java-modules/core-java-streams-7/src/main/java/com/baeldung/streams/gatherer/SlidingWindowGatherer.java +++ b/core-java-modules/core-java-streams-7/src/main/java/com/baeldung/streams/gatherer/SlidingWindowGatherer.java @@ -18,10 +18,8 @@ public Integrator, Integer, List> integrator() { @Override public boolean integrate(Deque state, Integer element, Downstream> downstream) { state.addLast(element); - if (state.size() == 3) { - downstream.push(new ArrayList<>(state)); - state.removeFirst(); - } + downstream.push(new ArrayList<>(state)); + state.removeFirst(); return true; } };