3737 .forEach(v - > System . out. println(v));
3838System . out. println(" Subscribed" );
3939```
40- Output
40+ [ Output] ( /tests/java/itrx/chapter3/leaving/ForEachExample.java )
4141```
4242Subscribed
43430
6060 .forEach(v - > System . out. println(v));
6161System . out. println(" Subscribed" );
6262```
63- Output
63+ [ Output] ( /tests/java/itrx/chapter3/leaving/ForEachExample.java )
6464```
65650
66661
@@ -86,7 +86,7 @@ catch (Exception e) {
8686}
8787System . out. println(" Subscribed" );
8888```
89- Output
89+ [ Output] ( /tests/java/itrx/chapter3/leaving/ForEachExample.java )
9090```
9191Caught: java.lang.Exception: Oops
9292Subscribed
@@ -105,7 +105,7 @@ long value = values
105105 .first(i - > i> 2 );
106106System . out. println(value);
107107```
108- Output
108+ [ Output] ( /tests/java/itrx/chapter3/leaving/FirstLastSingleExample.java )
109109```
1101103
111111```
@@ -128,7 +128,7 @@ catch (Exception e) {
128128 System . out. println(" Caught: " + e);
129129}
130130```
131- Output
131+ [ Output] ( /tests/java/itrx/chapter3/leaving/FirstLastSingleExample.java )
132132```
133133Caught: java.lang.IllegalArgumentException: Sequence contains too many elements
134134```
@@ -156,7 +156,7 @@ for (long l : iterable) {
156156 System . out. println(l);
157157}
158158```
159- Output
159+ [ Output] ( /tests/java/itrx/chapter3/leaving/IterablesExample.java )
160160```
1611610
1621621
@@ -188,7 +188,7 @@ for (long l : iterable) {
188188 Thread . sleep(750 );
189189}
190190```
191- Output
191+ [ Output] ( /tests/java/itrx/chapter3/leaving/IterablesExample.java )
192192```
193193Emitted: 0
1941940
@@ -223,7 +223,7 @@ for (long l : iterable) {
223223 Thread . sleep(750 );
224224}
225225```
226- Output
226+ [ Output] ( /tests/java/itrx/chapter3/leaving/IterablesExample.java )
227227```
228228Emitted: 0
2292290
@@ -260,7 +260,7 @@ for (long l : iterable) {
260260 Thread . sleep(400 );
261261}
262262```
263- Output
263+ [ Output] ( /tests/java/itrx/chapter3/leaving/IterablesExample.java )
264264```
265265-1
266266-1
@@ -288,7 +288,7 @@ values.subscribe(v -> System.out.println("Emitted: " + v));
288288Future<Long > future = values. toBlocking(). toFuture();
289289System . out. println(future. get());
290290```
291- Output
291+ [ Output] ( /tests/java/itrx/chapter3/leaving/FutureExample.java )
292292```
293293Emitted: 0
2942940
0 commit comments