Skip to content

Commit 0702d8f

Browse files
committed
Linked to examples
1 parent 9f21f30 commit 0702d8f

1 file changed

Lines changed: 10 additions & 10 deletions

File tree

Part 3 - Taming the sequence/6. Hot and Cold observables.md

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ cold.subscribe(i -> System.out.println("First: " + i));
1313
Thread.sleep(500);
1414
cold.subscribe(i -> System.out.println("Second: " + i));
1515
```
16-
Output
16+
[Output](/tests/java/itrx/chapter3/hotandcold/ColdExample.java)
1717
```
1818
First: 0
1919
First: 1
@@ -72,7 +72,7 @@ cold.subscribe(i -> System.out.println("First: " + i));
7272
Thread.sleep(500);
7373
cold.subscribe(i -> System.out.println("Second: " + i));
7474
```
75-
Output
75+
[Output](/tests/java/itrx/chapter3/hotandcold/ConnectableObservableExample.java)
7676
```
7777
First: 0
7878
First: 1
@@ -104,7 +104,7 @@ Thread.sleep(1000);
104104
System.out.println("Reconnecting");
105105
s = connectable.connect();
106106
```
107-
Output
107+
[Output](/tests/java/itrx/chapter3/hotandcold/ConnectableObservableExample.java)
108108
```
109109
0
110110
1
@@ -135,7 +135,7 @@ Thread.sleep(500);
135135
System.out.println("Unsubscribing second");
136136
s2.unsubscribe();
137137
```
138-
Output
138+
[Output](/tests/java/itrx/chapter3/hotandcold/ConnectableObservableExample.java)
139139
```
140140
First: 0
141141
First: 1
@@ -171,7 +171,7 @@ System.out.println("First connection again");
171171
Thread.sleep(500);
172172
s1 = cold.subscribe(i -> System.out.println("First: " + i));
173173
```
174-
Output
174+
[Output](/tests/java/itrx/chapter3/hotandcold/ConnectableObservableExample.java)
175175
```
176176
First: 0
177177
First: 1
@@ -215,7 +215,7 @@ System.out.println("Subscribe second");
215215
Subscription s2 = cold.subscribe(i -> System.out.println("Second: " + i));
216216
Thread.sleep(500);
217217
```
218-
Output
218+
[Output](/tests/java/itrx/chapter3/hotandcold/ReplayExample.java)
219219
```
220220
Subscribe first
221221
First: 0
@@ -259,7 +259,7 @@ source.connect();
259259
Thread.sleep(4500);
260260
source.subscribe(System.out::println);
261261
```
262-
Output
262+
[Output](/tests/java/itrx/chapter3/hotandcold/ReplayExample.java)
263263
```
264264
2
265265
3
@@ -279,7 +279,7 @@ source.connect();
279279
Thread.sleep(4500);
280280
source.subscribe(System.out::println);
281281
```
282-
Output
282+
[Output](/tests/java/itrx/chapter3/hotandcold/ReplayExample.java)
283283
```
284284
2
285285
3
@@ -306,7 +306,7 @@ obs.subscribe(i -> System.out.println("First: " + i));
306306
Thread.sleep(300);
307307
obs.subscribe(i -> System.out.println("Second: " + i));
308308
```
309-
Outout
309+
[Outout](/tests/java/itrx/chapter3/hotandcold/CacheExample.java)
310310
```
311311
First: 0
312312
First: 1
@@ -336,7 +336,7 @@ Subscription subscription = obs.subscribe();
336336
Thread.sleep(150);
337337
subscription.unsubscribe();
338338
```
339-
Output
339+
[Outout](/tests/java/itrx/chapter3/hotandcold/CacheExample.java)
340340
```
341341
Subscribed
342342
0

0 commit comments

Comments
 (0)