From d217a95cc3a67a6df8ac69eeb0c61f2d844fa45c Mon Sep 17 00:00:00 2001
From: Grzegorz Piwowarek <gpiwowarek@gmail.com>
Date: Tue, 22 Oct 2024 07:16:36 +0200
Subject: [PATCH] Terminate MoreGatherers.zip(Iterator) when Iterator doesn't
 have next element (#61)

---
 .../com/pivovarit/gatherers/ZipIteratorGatherer.java     | 9 +++------
 1 file changed, 3 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/pivovarit/gatherers/ZipIteratorGatherer.java b/src/main/java/com/pivovarit/gatherers/ZipIteratorGatherer.java
index db3cb5e..c235291 100644
--- 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();
     }
 }