accumulating with scan

javiergamarra · Nov 21, 2015 · 2a1f5e8 · 2a1f5e8
1 parent f84c073
commit 2a1f5e8
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/RxJavaInAction/src/com/nhpatt/rxjava/RxIsALibrary.java b/RxJavaInAction/src/com/nhpatt/rxjava/RxIsALibrary.java
@@ -87,4 +87,18 @@ public void filteringResults() {
                 .subscribe(System.out::println);
     }
 
+    @Test
+    public void accumulatingResults() {
+
+        service.listRepos("nhpatt")
+                .flatMap(Observable::from)
+                .map(Repo::getName)
+                .map((s) -> s.replace("-", " "))
+                .filter((s) -> s.startsWith("Android"))
+                .take(2)
+                .map(String::length)
+                .scan((x, y) -> x * y)
+                .subscribe(System.out::println);
+    }
+
 }