Skip to content

Commit 56351eb

Browse files
committed
2.4 Added nest examples
1 parent 9c5c39e commit 56351eb

File tree

1 file changed

+40
-0
lines changed

1 file changed

+40
-0
lines changed
Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
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+
}

0 commit comments

Comments
 (0)