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