We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cbd3a61 commit 63a52fcCopy full SHA for 63a52fc
Part 4 - Concurrency/3. Sequences of coincidence.md
@@ -30,23 +30,22 @@ Observable
30
.merge(
31
Observable.range(0, 5)
32
.window(3,1))
33
- .subscribe(new PrintSubscriber("Window"));
+ .subscribe(System.out::println);
34
```
35
Output
36
37
-Window: 0
38
-Window: 1
39
40
-Window: 2
41
42
43
-Window: 3
44
45
46
-Window: 4
47
48
49
-Window: Completed
+0
+1
+2
+3
+4
50
51
52
We can see here that the inner observables are emitting the same value simultaneously, if that value belongs to multiple windows.
0 commit comments