We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
nest
1 parent 9c5c39e commit 56351ebCopy full SHA for 56351eb
1 file changed
tests/java/itrx/chapter2/aggregation/NestTest.java
@@ -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
32
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