| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| amb_variadic.cpp | 14 auto ys2 = sc.make_hot_observable({ variable
27 | rxo::amb(ys2, ys3)
47 THEN("there was one subscription and one unsubscription to the ys2"){
51 auto actual = ys2.subscriptions();
76 auto ys2 = sc.make_hot_observable({ variable
86 .amb(ys2)
108 THEN("there was one subscription and one unsubscription to the ys2"){
112 auto actual = ys2.subscriptions();
130 auto ys2 = sc.make_hot_observable({ variable
139 .amb(ys2)
185 auto ys2 = sc.make_cold_observable({ variable
263 auto ys2 = sc.make_cold_observable({ variable
341 auto ys2 = sc.make_cold_observable({ variable
419 auto ys2 = sc.make_cold_observable({ variable
494 auto ys2 = sc.make_cold_observable({ variable
565 auto ys2 = sc.make_hot_observable({ variable
[all...] |
| amb.cpp | 15 auto ys2 = sc.make_hot_observable({ variable
25 o_on.next(100, ys2),
63 THEN("there was one subscription and one unsubscription to the ys2"){
67 auto actual = ys2.subscriptions();
93 auto ys2 = sc.make_hot_observable({ variable
100 o_on.next(100, ys2),
139 THEN("there was one subscription and one unsubscription to the ys2"){
143 auto actual = ys2.subscriptions();
164 auto ys2 = sc.make_cold_observable({ variable
180 o_on.next(100, ys2),
258 auto ys2 = sc.make_cold_observable({ variable
352 auto ys2 = sc.make_cold_observable({ variable
441 auto ys2 = sc.make_cold_observable({ variable
525 auto ys2 = sc.make_cold_observable({ variable
609 auto ys2 = sc.make_cold_observable({ variable
742 auto ys2 = sc.make_cold_observable({ variable
833 auto ys2 = sc.make_cold_observable({ variable
922 auto ys2 = sc.make_hot_observable({ variable
[all...] |
| buffer.cpp | 659 auto ys2 = rx::observable<>::error<long, std::runtime_error>(std::runtime_error("buffer_with_time on_error from source"), so); variable
660 ys1.concat(so, ys2)
[all...] |
| merge_delay_error.cpp | 25 auto ys2 = sc.make_cold_observable({ variable
44 o_on.next(400, ys2),
99 THEN("there was one subscription and one unsubscription to the ys2"){
103 auto actual = ys2.subscriptions();
135 auto ys2 = sc.make_cold_observable({ variable
139 on.error(40, std::runtime_error("merge_delay_error on_error from ys2")),
158 .merge_delay_error(ys2, ys3);
193 THEN("there was one subscription and one unsubscription to the ys2"){
197 auto actual = ys2.subscriptions();
230 auto ys2 = sc.make_cold_observable( variable
[all...] |
| switch_on_next.cpp | 21 auto ys2 = sc.make_cold_observable({ variable
39 o_on.next(400, ys2),
87 THEN("there was 1 subscription/unsubscription to ys2"){
91 auto actual = ys2.subscriptions();
125 auto ys2 = sc.make_cold_observable({ variable
143 o_on.next(400, ys2),
186 THEN("there was 1 subscription/unsubscription to ys2"){
190 auto actual = ys2.subscriptions();
222 auto ys2 = sc.make_cold_observable({ variable
232 o_on.next(400, ys2),
[all...] |
| concat.cpp | 110 auto ys2 = sc.make_cold_observable({ variable
129 o_on.next(400, ys2),
184 THEN("there was one subscription and one unsubscription to the ys2"){
188 auto actual = ys2.subscriptions();
|
| merge.cpp | 110 auto ys2 = sc.make_cold_observable({ variable
129 o_on.next(400, ys2),
184 THEN("there was one subscription and one unsubscription to the ys2"){
188 auto actual = ys2.subscriptions();
220 auto ys2 = sc.make_cold_observable({ variable
242 .merge(ys2, ys3);
277 THEN("there was one subscription and one unsubscription to the ys2"){
281 auto actual = ys2.subscriptions();
|
