Skip to content

Commit 9f21f30

Browse files
FroussiosFroussios
committed
Linked examples
1 parent a1299c2 commit 9f21f30

1 file changed

Lines changed: 18 additions & 18 deletions

File tree

‎Part 3 - Taming the sequence/5. Time-shifted sequences.md‎

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ Observable.range(0, 10)
2121
.buffer(4)
2222
.subscribe(System.out::println);
2323
```
24-
Output
24+
[Output](/tests/java/itrx/chapter3/timeshifted/BufferExample.java)
2525
```
2626
[0, 1, 2, 3]
2727
[4, 5, 6, 7]
@@ -41,7 +41,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS).take(10)
4141
.buffer(250, TimeUnit.MILLISECONDS)
4242
.subscribe(System.out::println);
4343
```
44-
Output
44+
[Output](/tests/java/itrx/chapter3/timeshifted/BufferExample.java)
4545
```
4646
[0, 1]
4747
[2, 3]
@@ -62,7 +62,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS)
6262
.buffer(250, TimeUnit.MILLISECONDS, 2)
6363
.subscribe(System.out::println);
6464
```
65-
Output
65+
[Output](/tests/java/itrx/chapter3/timeshifted/BufferExample.java)
6666
```
6767
[0, 1]
6868
[]
@@ -141,7 +141,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS).take(10)
141141
.buffer(350, 200, TimeUnit.MILLISECONDS)
142142
.subscribe(System.out::println);
143143
```
144-
Output
144+
[Output](/tests/java/itrx/chapter3/timeshifted/BufferExample.java)
145145
```
146146
[0, 1, 2]
147147
[2, 3, 4]
@@ -171,7 +171,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS).take(10)
171171
i -> Observable.timer(200, TimeUnit.MILLISECONDS))
172172
.subscribe(System.out::println);
173173
```
174-
Output
174+
[Output](/tests/java/itrx/chapter3/timeshifted/BufferExample.java)
175175
```
176176
[2, 3]
177177
[4, 5]
@@ -196,7 +196,7 @@ Observable.range(0, 5)
196196
.takeLastBuffer(2)
197197
.subscribe(System.out::println);
198198
```
199-
Output
199+
[Output](/tests/java/itrx/chapter3/timeshifted/TakeLastBufferExample.java)
200200
```
201201
[3, 4]
202202
```
@@ -213,7 +213,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS)
213213
.takeLastBuffer(200, TimeUnit.MILLISECONDS)
214214
.subscribe(System.out::println);
215215
```
216-
Output
216+
[Output](/tests/java/itrx/chapter3/timeshifted/TakeLastBufferExample.java)
217217
```
218218
[2, 3, 4]
219219
```
@@ -228,7 +228,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS)
228228
.takeLastBuffer(2, 200, TimeUnit.MILLISECONDS)
229229
.subscribe(System.out::println);
230230
```
231-
Output
231+
[Output](/tests/java/itrx/chapter3/timeshifted/TakeLastBufferExample.java)
232232
```
233233
[3, 4]
234234
```
@@ -254,7 +254,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS).take(5)
254254
.timeInterval()
255255
.subscribe(System.out::println);
256256
```
257-
Output
257+
[Output](/tests/java/itrx/chapter3/timeshifted/DelayExample.java)
258258
```
259259
TimeInterval [intervalInMilliseconds=1109, value=0]
260260
TimeInterval [intervalInMilliseconds=94, value=1]
@@ -275,7 +275,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS).take(5)
275275
.timeInterval()
276276
.subscribe(System.out::println);
277277
```
278-
Output
278+
[Output](/tests/java/itrx/chapter3/timeshifted/DelayExample.java)
279279
```
280280
TimeInterval [intervalInMilliseconds=152, value=0]
281281
TimeInterval [intervalInMilliseconds=173, value=1]
@@ -297,7 +297,7 @@ Observable.interval(100, TimeUnit.MILLISECONDS).take(5)
297297
.timeInterval()
298298
.subscribe(System.out::println);
299299
```
300-
Output
300+
[Output](/tests/java/itrx/chapter3/timeshifted/DelayExample.java)
301301
```
302302
TimeInterval [intervalInMilliseconds=1114, value=0]
303303
TimeInterval [intervalInMilliseconds=92, value=1]
@@ -345,7 +345,7 @@ Observable.interval(150, TimeUnit.MILLISECONDS)
345345
.sample(1, TimeUnit.SECONDS)
346346
.subscribe(System.out::println);
347347
```
348-
Output
348+
[Output](/tests/java/itrx/chapter3/timeshifted/SampleExample.java)
349349
```
350350
5
351351
12
@@ -379,7 +379,7 @@ Observable.interval(150, TimeUnit.MILLISECONDS)
379379
.throttleFirst(1, TimeUnit.SECONDS)
380380
.subscribe(System.out::println);
381381
```
382-
Output
382+
[Output](/tests/java/itrx/chapter3/timeshifted/ThrottleExample.java)
383383
```
384384
0
385385
7
@@ -400,7 +400,7 @@ Observable.interval(150, TimeUnit.MILLISECONDS)
400400
.throttleLast(1, TimeUnit.SECONDS)
401401
.subscribe(System.out::println);
402402
```
403-
Output
403+
[Output](/tests/java/itrx/chapter3/timeshifted/ThrottleExample.java)
404404
```
405405
5
406406
12
@@ -456,7 +456,7 @@ Observable.concat(
456456
.debounce(150, TimeUnit.MILLISECONDS)
457457
.subscribe(System.out::println);
458458
```
459-
Output
459+
[Output](/tests/java/itrx/chapter3/timeshifted/DebounceExample.java)
460460
```
461461
3
462462
4
@@ -485,7 +485,7 @@ Observable.concat(
485485
.debounce(i -> Observable.timer(i * 50, TimeUnit.MILLISECONDS))
486486
.subscribe(System.out::println);
487487
```
488-
Output
488+
[Output](/tests/java/itrx/chapter3/timeshifted/DebounceExample.java)
489489
```
490490
1
491491
3
@@ -535,7 +535,7 @@ Observable.concat(
535535
System.out::println,
536536
System.out::println);
537537
```
538-
Output
538+
[Output](/tests/java/itrx/chapter3/timeshifted/TimeoutExample.java)
539539
```
540540
0
541541
1
@@ -562,7 +562,7 @@ Observable.concat(
562562
System.out::println,
563563
System.out::println);
564564
```
565-
Output
565+
[Output](/tests/java/itrx/chapter3/timeshifted/TimeoutExample.java)
566566
```
567567
0
568568
1

0 commit comments

Comments
 (0)