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> initializer() { @Override public Integrator, 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(); } }