feat: Add collectWhile operator. (#964)

2024-01-17 01:07:47 +08:00 · 2024-01-17 01:07:47 +08:00 · 19da73673d
commit 19da73673d
parent 11ba3d7bef
13 changed files with 347 additions and 4 deletions
--- a/docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java
+++ b/docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java
@ -401,6 +401,17 @@ class SourceOrFlow {
    // #collect
  }

+  void collectWhileExample() {
+    // #collectWhile
+    Flow<Message, Pong, NotUsed> flow =
+        Flow.of(Message.class)
+            .collectWhile(
+                PFBuilder.<Message, Pong>create()
+                    .match(Ping.class, p -> p.id <= 100, p -> new Pong(p.id))
+                    .build());
+    // #collectWhile
+  }
+
  void collectTypeExample() {
    // #collectType
    Flow<Message, Pong, NotUsed> flow =