add bufferWhile/bufferUntil builder accumulator convenience method

davidmoten · Dec 3, 2024 · 63b65ef · 63b65ef
1 parent 5e0cb6c
commit 63b65ef
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/kool/src/main/java/org/davidmoten/kool/BufferBuilder.java b/kool/src/main/java/org/davidmoten/kool/BufferBuilder.java
@@ -4,6 +4,7 @@
 import java.util.List;
 import java.util.concurrent.Callable;
 
+import org.davidmoten.kool.function.BiConsumer;
 import org.davidmoten.kool.function.BiFunction;
 import org.davidmoten.kool.function.BiPredicate;
 import org.davidmoten.kool.function.Function;
@@ -93,6 +94,11 @@ public BuilderHasAccumulator<T, S> accumulator(BiFunction<? super S, ? super T,
             b.accumulator = accumulator;
             return new BuilderHasAccumulator<T, S>(b);
         }
+
+        public BuilderHasAccumulator<T, S> accumulator(BiConsumer<? super S, ? super T> accumulator) {
+            b.accumulator = (buffer, t) -> {accumulator.accept(buffer, t); return buffer;};
+            return new BuilderHasAccumulator<T, S>(b);
+        }
     }
 
     public static final class BuilderHasAccumulator<T, S> {