Skip to content

Commit a1299c2

Browse files
FroussiosFroussios
committed
Linked to examples
1 parent b3700d1 commit a1299c2

1 file changed

Lines changed: 19 additions & 19 deletions

File tree

‎Part 3 - Taming the sequence/4. Combining sequences.md‎

Lines changed: 19 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ Observable<Integer> seq2 = Observable.range(10, 3);
3636
Observable.concat(seq1, seq2)
3737
.subscribe(System.out::println);
3838
```
39-
Output
39+
[Output](/tests/java/itrx/chapter3/combining/ConcatExample.java)
4040
```
4141
0
4242
1
@@ -61,7 +61,7 @@ Observable<String> words = Observable.just(
6161
Observable.concat(words.groupBy(v -> v.charAt(0)))
6262
.subscribe(System.out::println);
6363
```
64-
Output
64+
[Output](/tests/java/itrx/chapter3/combining/ConcatExample.java)
6565
```
6666
First
6767
Fourth
@@ -86,7 +86,7 @@ public void exampleConcatWith() {
8686
.subscribe(System.out::println);
8787
}
8888
```
89-
Output
89+
[Output](/tests/java/itrx/chapter3/combining/ConcatExample.java)
9090
```
9191
0
9292
1
@@ -114,7 +114,7 @@ Observable<Integer> words = Observable.range(0,2);
114114
words.repeat(2)
115115
.subscribe(System.out::println);
116116
```
117-
Output
117+
[Output](/tests/java/itrx/chapter3/combining/RepeatExample.java)
118118
```
119119
0
120120
1
@@ -149,7 +149,7 @@ values
149149
})
150150
.subscribe(new PrintSubscriber("repeatWhen"));
151151
```
152-
Output
152+
[Output](/tests/java/itrx/chapter3/combining/RepeatExample.java)
153153
```
154154
repeatWhen: 0
155155
repeatWhen: 1
@@ -200,7 +200,7 @@ Observable<Integer> values = Observable.range(0, 3);
200200
values.startWith(-1,-2)
201201
.subscribe(System.out::println);
202202
```
203-
Output
203+
[Output](/tests/java/itrx/chapter3/combining/StartWithExample.java)
204204
```
205205
-1
206206
-2
@@ -250,7 +250,7 @@ Observable.amb(
250250
Observable.timer(50, TimeUnit.MILLISECONDS).map(i -> "Second"))
251251
.subscribe(System.out::println);
252252
```
253-
Output
253+
[Output](/tests/java/itrx/chapter3/combining/AmbExample.java)
254254
```
255255
Second
256256
```
@@ -266,7 +266,7 @@ Observable.timer(100, TimeUnit.MILLISECONDS).map(i -> "First")
266266
.ambWith(Observable.timer(70, TimeUnit.MILLISECONDS).map(i -> "Third"))
267267
.subscribe(System.out::println);
268268
```
269-
Output
269+
[Output](/tests/java/itrx/chapter3/combining/AmbExample.java)
270270
```
271271
Second
272272
```
@@ -306,7 +306,7 @@ Observable.merge(
306306
.take(10)
307307
.subscribe(System.out::println);
308308
```
309-
Output
309+
[Output](/tests/java/itrx/chapter3/combining/MergeExample.java)
310310
```
311311
Second
312312
First
@@ -365,7 +365,7 @@ Observable.mergeDelayError(failAt200, completeAt400)
365365
System.out::println,
366366
System.out::println);
367367
```
368-
Output
368+
[Output](/tests/java/itrx/chapter3/combining/MergeDelayErrorExample.java)
369369
```
370370
0
371371
0
@@ -398,7 +398,7 @@ Observable.mergeDelayError(failAt200, failAt300, completeAt400)
398398
System.out::println,
399399
System.out::println);
400400
```
401-
Output
401+
[Output](/tests/java/itrx/chapter3/combining/MergeDelayErrorExample.java)
402402
```
403403
0
404404
0
@@ -431,7 +431,7 @@ Observable.switchOnNext(
431431
.take(9)
432432
.subscribe(System.out::println);
433433
```
434-
Output
434+
[Output](/tests/java/itrx/chapter3/combining/SwitchOnNextExample.java)
435435
```
436436
0
437437
0
@@ -465,7 +465,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS)
465465
.take(9)
466466
.subscribe(System.out::println);
467467
```
468-
Output
468+
[Output](/tests/java/itrx/chapter3/combining/SwitchMapExample.java)
469469
```
470470
0
471471
0
@@ -501,7 +501,7 @@ Observable.zip(
501501
.take(6)
502502
.subscribe(System.out::println);
503503
```
504-
Output
504+
[Output](/tests/java/itrx/chapter3/combining/ZipExample.java)
505505
```
506506
Left emits 0
507507
Right emits 0
@@ -560,7 +560,7 @@ Observable.zip(
560560
.take(6)
561561
.subscribe(System.out::println);
562562
```
563-
Output
563+
[Output](/tests/java/itrx/chapter3/combining/ZipExample.java)
564564
```
565565
0 - 0 - 0
566566
1 - 1 - 1
@@ -581,7 +581,7 @@ Observable.zip(
581581
.count()
582582
.subscribe(System.out::println);
583583
```
584-
Output
584+
[Output](/tests/java/itrx/chapter3/combining/ZipExample.java)
585585
```
586586
3
587587
```
@@ -599,7 +599,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS)
599599
.take(6)
600600
.subscribe(System.out::println);
601601
```
602-
Output
602+
[Output](/tests/java/itrx/chapter3/combining/ZipExample.java)
603603
```
604604
0 - 0
605605
1 - 1
@@ -618,7 +618,7 @@ Observable.range(0, 5)
618618
(i1,i2) -> i1 + " - " + i2)
619619
.subscribe(System.out::println);
620620
```
621-
Output
621+
[Output](/tests/java/itrx/chapter3/combining/ZipExample.java)
622622
```
623623
0 - 0
624624
1 - 2
@@ -644,7 +644,7 @@ Observable.combineLatest(
644644
.take(6)
645645
.subscribe(System.out::println);
646646
```
647-
Output
647+
[Output](/tests/java/itrx/chapter3/combining/CombineLatestExample.java)
648648
```
649649
Left emits
650650
Right emits

0 commit comments

Comments
 (0)