Implement Greedy

tginsberg · Jan 22, 2025 · 786aa30 · 786aa30
1 parent 31006b0
commit 786aa30
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/ginsberg/gatherers4j/EveryNthGatherer.java b/src/main/java/com/ginsberg/gatherers4j/EveryNthGatherer.java
@@ -40,12 +40,12 @@ public Supplier<State> initializer() {
 
     @Override
     public Integrator<EveryNthGatherer.State, INPUT, INPUT> integrator() {
-        return (state, element, downstream) -> {
+        return Integrator.ofGreedy((state, element, downstream) -> {
             if (state.size++ % count == 0) {
                 downstream.push(element);
             }
             return !downstream.isRejecting();
-        };
+        });
     }
 
     public static class State {