Skip to content

Commit be7e554

Browse files
authored
Merge pull request #18855 from likhith5697/fix-sliding-window-optimization
Optimize SlidingWindowGatherer: remove unused finisher and always push current state
2 parents 4726185 + aae2714 commit be7e554

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

core-java-modules/core-java-streams-7/src/main/java/com/baeldung/streams/gatherer/SlidingWindowGatherer.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,10 +18,8 @@ public Integrator<Deque<Integer>, Integer, List<Integer>> integrator() {
1818
@Override
1919
public boolean integrate(Deque<Integer> state, Integer element, Downstream<? super List<Integer>> downstream) {
2020
state.addLast(element);
21-
if (state.size() == 3) {
22-
downstream.push(new ArrayList<>(state));
23-
state.removeFirst();
24-
}
21+
downstream.push(new ArrayList<>(state));
22+
state.removeFirst();
2523
return true;
2624
}
2725
};

0 commit comments

Comments
 (0)