Adding example of fold for sink #25468

2020-09-21 21:31:14 +05:30 · 2020-09-21 21:31:14 +05:30 · ac648a5940
commit ac648a5940
parent b7640c3261
3 changed files with 42 additions and 0 deletions
--- a/akka-docs/src/test/java/jdocs/stream/operators/SinkDocExamples.java
+++ b/akka-docs/src/test/java/jdocs/stream/operators/SinkDocExamples.java
@ -105,6 +105,15 @@ public class SinkDocExamples {
    // #lastOption-operator-example
  }

+  static void foldExample() {
+    // #fold
+    Source<Integer, NotUsed> source = Source.range(1, 100);
+    CompletionStage<Integer> sum =
+        source.runWith(Sink.fold(0, (res, element) -> res + element), system);
+    sum.thenAccept(System.out::println);
+    // #fold
+  }
+
  static void ignoreExample() {
    // #ignore
    Source<String, NotUsed> lines = readLinesFromFile();