add tests

davidmoten · Dec 3, 2024 · 8c1933c · 8c1933c
1 parent a78fb82
commit 8c1933c
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/kool/src/test/java/org/davidmoten/kool/StreamTest.java b/kool/src/test/java/org/davidmoten/kool/StreamTest.java
@@ -892,6 +892,24 @@ public void testBufferWhileWithStepSmallerThanBufferedListDontEmitRemainderUseBu
                         Lists.newArrayList(2, 3, 4, 5), //
                         Lists.newArrayList(3, 4, 5, 6));
     }
+
+    @Test
+    public void testBufferWhileWithStepSmallerThanBufferedListDontEmitRemainderUseBuilderWithFactory() {
+        Stream.of(1, 2, 3, 4, 5, 6, 7) //
+                .bufferWhile() //
+                .factory(ArrayList::new) //
+                .condition((list, t) -> list.size() <= 3) //
+                .accumulator((list, t)-> {list.add(t); return list;}) //
+                .step(1) //
+                .emitRemainder(false) //
+                .maxReplay(100)
+                .build()
+                .test() //
+                .assertValuesOnly( //
+                        Lists.newArrayList(1, 2, 3, 4), //
+                        Lists.newArrayList(2, 3, 4, 5), //
+                        Lists.newArrayList(3, 4, 5, 6));
+    }
 
     @Test(expected = NoSuchElementException.class)
     public void testBufferUntilWithStepWhenEmptyAndNextCalled() {