Terminate MoreGatherers.zip(Iterator) when Iterator doesn't have next…

… element (#61)
pivovarit · Oct 22, 2024 · d217a95 · d217a95
1 parent e0e50b1
commit d217a95
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/src/main/java/com/pivovarit/gatherers/ZipIteratorGatherer.java b/src/main/java/com/pivovarit/gatherers/ZipIteratorGatherer.java
@@ -21,11 +21,8 @@ public Supplier<Iterator<T2>> initializer() {
 
     @Override
     public Integrator<Iterator<T2>, T1, R> integrator() {
-        return (state, element, downstream) -> {
-            if (state.hasNext()) {
-                return downstream.push(mapper.apply(element, state.next()));
-            }
-            return true;
-        };
+        return (state, element, downstream) -> state.hasNext()
+          ? downstream.push(mapper.apply(element, state.next()))
+          : state.hasNext();
     }
 }