| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | window_toggle.cpp | 12 const rxsc::test::messages<std::string> o_on; variable
62 o_on.next(261, "0 4"),
63 o_on.next(341, "1 6"),
64 o_on.next(411, "1 7"),
65 o_on.next(411, "3 7"),
66 o_on.next(421, "1 8"),
67 o_on.next(421, "3 8"),
68 o_on.next(471, "3 9"),
69 o_on.completed(591)
77 o_on.subscribe(200, 590)
[all …]
|
| D | amb.cpp | 9 const rxsc::test::messages<rx::observable<int>> o_on; variable
24 o_on.next(100, ys1),
25 o_on.next(100, ys2),
26 o_on.next(100, ys3),
27 o_on.completed(200)
87 const rxsc::test::messages<rx::observable<int>> o_on; variable
99 o_on.next(100, ys1),
100 o_on.next(100, ys2),
101 o_on.completed(150)
155 const rxsc::test::messages<rx::observable<int>> o_on; variable
[all …]
|
| D | switch_on_next.cpp | 9 const rxsc::test::messages<rx::observable<int>> o_on; variable
38 o_on.next(300, ys1),
39 o_on.next(400, ys2),
40 o_on.next(500, ys3),
41 o_on.completed(600)
73 o_on.subscribe(200, 600)
111 const rxsc::test::messages<rx::observable<int>> o_on; variable
142 o_on.next(300, ys1),
143 o_on.next(400, ys2),
144 o_on.next(500, ys3),
[all …]
|
| D | sequence_equal.cpp | 142 const rxsc::test::messages<bool> o_on; variable
174 o_on.next(610, true),
175 o_on.completed(610)
197 const rxsc::test::messages<bool> o_on; variable
228 o_on.next(610, false),
229 o_on.completed(610)
251 const rxsc::test::messages<bool> o_on; variable
282 o_on.next(610, false),
283 o_on.completed(610)
305 const rxsc::test::messages<bool> o_on; variable
[all …]
|
| D | window.cpp | 14 const rxsc::test::messages<rx::observable<int>> o_on; variable
61 o_on.subscribe(200, 600)
75 const rxsc::test::messages<rx::observable<int>> o_on; variable
177 o_on.subscribe(200, 600)
191 const rxsc::test::messages<rx::observable<int>> o_on; variable
234 o_on.subscribe(200, 370)
248 const rxsc::test::messages<rx::observable<int>> o_on; variable
297 o_on.subscribe(200, 600)
312 const rxsc::test::messages<rx::observable<int>> o_on; variable
367 o_on.subscribe(200, 490)
[all …]
|
| D | merge_delay_error.cpp | 13 const rxsc::test::messages<rx::observable<int>> o_on; variable
43 o_on.next(300, ys1),
44 o_on.next(400, ys2),
45 o_on.next(500, ys3),
46 o_on.completed(600)
123 const rxsc::test::messages<rx::observable<int>> o_on; variable
217 const rxsc::test::messages<rx::observable<int>> o_on; variable
|
| D | concat.cpp | 98 const rxsc::test::messages<rx::observable<int>> o_on; variable
128 o_on.next(300, ys1),
129 o_on.next(400, ys2),
130 o_on.next(500, ys3),
131 o_on.completed(600)
|
| D | merge.cpp | 98 const rxsc::test::messages<rx::observable<int>> o_on; variable
128 o_on.next(300, ys1),
129 o_on.next(400, ys2),
130 o_on.next(500, ys3),
131 o_on.completed(600)
208 const rxsc::test::messages<rx::observable<int>> o_on; variable
|