File tree Expand file tree Collapse file tree 1 file changed +40
-0
lines changed
tests/java/itrx/chapter2/aggregation Expand file tree Collapse file tree 1 file changed +40
-0
lines changed Original file line number Diff line number Diff line change 1+ package itrx .chapter2 .aggregation ;
2+
3+ import java .util .Arrays ;
4+
5+ import org .junit .Test ;
6+
7+ import rx .Observable ;
8+ import rx .observers .TestSubscriber ;
9+
10+ public class NestTest {
11+
12+ public void example () {
13+ Observable .range (0 , 3 )
14+ .nest ()
15+ .subscribe (ob -> ob .subscribe (System .out ::println ));
16+
17+ // 0
18+ // 1
19+ // 2
20+ }
21+
22+
23+ //
24+ // Test
25+ //
26+
27+ @ Test
28+ public void test () {
29+ TestSubscriber <Integer > tester = new TestSubscriber <>();
30+
31+ Observable .range (0 , 3 )
32+ .nest ()
33+ .subscribe (ob -> ob .subscribe (tester ));
34+
35+ tester .assertReceivedOnNext (Arrays .asList (0 ,1 ,2 ));
36+ tester .assertTerminalEvent ();
37+ tester .assertNoErrors ();
38+ }
39+
40+ }
You can’t perform that action at this time.
0 commit comments