| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | take.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(150, 1),
12 on.next(210, 2),
13 on.next(220, 3),
14 on.next(230, 4),
15 on.next(240, 5),
16 on.completed(250)
32 on.next(210, 2),
33 on.next(220, 3),
34 on.completed(220)
[all …]
|
| D | take_while.cpp | 19 const rxsc::test::messages<int> on; variable
22 on.next(150, 1),
23 on.next(210, 2),
24 on.next(220, 3),
25 on.next(230, 4),
26 on.next(240, 5),
27 on.completed(250)
42 on.next(210, 2),
43 on.next(220, 3),
44 on.completed(230)
[all …]
|
| D | skip.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(70, 6),
12 on.next(150, 4),
13 on.next(210, 9),
14 on.next(230, 13),
15 on.next(270, 7),
16 on.next(280, 1),
17 on.next(300, -1),
18 on.next(310, 3),
19 on.next(340, 8),
[all …]
|
| D | skip_while.cpp | 19 const rxsc::test::messages<int> on; variable
22 on.next(150, 1),
23 on.next(210, 2),
24 on.next(220, 3),
25 on.next(230, 4),
26 on.next(240, 5),
27 on.completed(250)
42 on.next(230, 4),
43 on.next(240, 5),
44 on.completed(250)
[all …]
|
| D | window.cpp | 13 const rxsc::test::messages<int> on; variable
17 on.next(100, 1),
18 on.next(210, 2),
19 on.next(240, 3),
20 on.next(280, 4),
21 on.next(320, 5),
22 on.next(350, 6),
23 on.next(380, 7),
24 on.next(420, 8),
25 on.next(470, 9),
[all …]
|
| D | merge_delay_error.cpp | 12 const rxsc::test::messages<int> on; variable
16 on.next(10, 101),
17 on.next(20, 102),
18 on.next(110, 103),
19 on.next(120, 104),
20 on.next(210, 105),
21 on.next(220, 106),
22 on.completed(230)
26 on.next(10, 201),
27 on.next(20, 202),
[all …]
|
| D | replay.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(110, 0),
12 on.next(220, 1),
13 on.next(280, 2),
14 on.next(290, 3),
15 on.next(340, 4),
16 on.next(360, 5),
17 on.next(370, 6),
18 on.next(390, 7),
19 on.next(410, 8),
[all …]
|
| D | retry.cpp | 8 const rxsc::test::messages<int> on; variable
12 on.next(300, 1),
13 on.next(325, 2),
14 on.next(350, 3),
15 on.error(400, ex),
16 on.next(425, 1),
17 on.next(450, 2),
18 on.next(475, 3),
19 on.next(500, 4),
20 on.error(525, ex),
[all …]
|
| D | filter.cpp | 21 const rxsc::test::messages<int> on; variable
26 on.next(110, 1),
27 on.next(180, 2),
28 on.next(230, 3),
29 on.next(270, 4),
30 on.next(340, 5),
31 on.next(380, 6),
32 on.next(390, 7),
33 on.next(450, 8),
34 on.next(470, 9),
[all …]
|
| D | distinct_until_changed.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(150, 1)
30 on.subscribe(200, 1000)
43 const rxsc::test::messages<int> on; variable
46 on.next(150, 1),
47 on.completed(250)
60 on.completed(250)
68 on.subscribe(200, 250)
82 const rxsc::test::messages<int> on; variable
85 on.next(150, 1),
[all …]
|
| D | repeat.cpp | 9 const rxsc::test::messages<int> on; variable
12 on.next(100, 1),
13 on.next(150, 2),
14 on.next(200, 3),
15 on.completed(250)
31 on.next(300, 1),
32 on.next(350, 2),
33 on.next(400, 3),
34 on.next(550, 1),
35 on.next(600, 2),
[all …]
|
| D | sequence_equal.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(150, 1)
15 on.next(150, 1),
16 on.next(200, 2),
17 on.next(300, 3),
18 on.next(400, 4),
19 on.next(500, 5),
20 on.completed(600)
41 on.subscribe(200, 1000)
54 const rxsc::test::messages<int> on; variable
[all …]
|
| D | switch_on_next.cpp | 8 const rxsc::test::messages<int> on; variable
12 on.next(10, 101),
13 on.next(20, 102),
14 on.next(110, 103),
15 on.next(120, 104),
16 on.next(210, 105),
17 on.next(220, 106),
18 on.completed(230)
22 on.next(10, 201),
23 on.next(20, 202),
[all …]
|
| D | amb_variadic.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(100, 1)
15 on.next(110, 2)
19 on.next(120, 3)
41 on.subscribe(200, 1000)
49 on.subscribe(200, 1000)
57 on.subscribe(200, 1000)
70 const rxsc::test::messages<int> on; variable
73 on.next(100, 1)
77 on.next(110, 2),
[all …]
|
| D | take_until.cpp | 9 const rxsc::test::messages<int> on; variable
12 on.next(150, 1),
13 on.next(210, 2),
14 on.next(220, 3),
15 on.next(230, 4),
16 on.next(240, 5),
17 on.completed(250)
21 on.next(150, 1),
22 on.next(225, 99),
23 on.completed(230)
[all …]
|
| D | distinct.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(150, 1)
33 on.subscribe(200, 1000)
46 const rxsc::test::messages<int> on; variable
49 on.next(150, 1),
50 on.completed(250)
65 on.completed(250)
73 on.subscribe(200, 250)
87 const rxsc::test::messages<int> on; variable
90 on.next(150, 1),
[all …]
|
| D | merge.cpp | 97 const rxsc::test::messages<int> on; variable
101 on.next(10, 101),
102 on.next(20, 102),
103 on.next(110, 103),
104 on.next(120, 104),
105 on.next(210, 105),
106 on.next(220, 106),
107 on.completed(230)
111 on.next(10, 201),
112 on.next(20, 202),
[all …]
|
| D | amb.cpp | 8 const rxsc::test::messages<int> on; variable
12 on.next(100, 1)
16 on.next(110, 2)
20 on.next(120, 3)
49 on.subscribe(200, 400)
57 on.subscribe(300, 1000)
65 on.subscribe(300, 1000)
73 on.subscribe(300, 1000)
86 const rxsc::test::messages<int> on; variable
90 on.next(100, 1)
[all …]
|
| D | zip.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(150, 1)
15 on.next(150, 1)
42 on.subscribe(200, 1000)
50 on.subscribe(200, 1000)
63 const rxsc::test::messages<int> on; variable
71 on.next(150, 1)
102 on.subscribe(200, 1000) in __anon117b13840502()
116 const rxsc::test::messages<int> on; variable
119 on.next(150, 1)
[all …]
|
| D | combine_latest.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(150, 1),
12 on.next(215, 2),
13 on.next(225, 4),
14 on.completed(230)
18 on.next(150, 1),
19 on.next(220, 3),
20 on.next(230, 5),
21 on.next(235, 6),
22 on.next(240, 7),
[all …]
|
| D | on_error_resume_next.cpp | 8 const rxsc::test::messages<int> on; variable
12 on.next(180, 1),
13 on.next(210, 2),
14 on.next(240, 3),
15 on.next(290, 4),
16 on.next(350, 5),
17 on.completed(400),
18 on.next(410, -1),
19 on.completed(420),
20 on.error(430, std::runtime_error("error on unsubscribed stream"))
[all …]
|
| D | with_latest_from.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(150, 1),
12 on.next(215, 2),
13 on.next(225, 4),
14 on.completed(230)
18 on.next(150, 1),
19 on.next(220, 3),
20 on.next(230, 5),
21 on.next(235, 6),
22 on.next(240, 7),
[all …]
|
| D | skip_until.cpp | 8 const rxsc::test::messages<int> on; variable
11 on.next(150, 1),
12 on.next(210, 2),
13 on.next(220, 3),
14 on.next(230, 4),
15 on.next(240, 5),
16 on.completed(250)
20 on.next(150, 1),
21 on.next(225, 99),
22 on.completed(230)
[all …]
|
| D | sample.cpp | 9 const rxsc::test::messages<int> on; variable
14 on.next(100, 1),
15 on.next(210, 2),
16 on.next(240, 3),
17 on.next(280, 4),
18 on.next(320, 5),
19 on.next(350, 6),
20 on.next(380, 7),
21 on.next(420, 8),
22 on.next(470, 9),
[all …]
|
| D | window_toggle.cpp | 11 const rxsc::test::messages<int> on; variable
15 on.next(90, 1),
16 on.next(180, 2),
17 on.next(250, 3),
18 on.next(260, 4),
19 on.next(310, 5),
20 on.next(340, 6),
21 on.next(410, 7),
22 on.next(420, 8),
23 on.next(470, 9),
[all …]
|