Home
last modified time | relevance | path

Searched refs:make_cold_observable (Results 1 – 15 of 15) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Damb.cpp23 auto xs = sc.make_cold_observable({
98 auto xs = sc.make_cold_observable({
157 auto ys1 = sc.make_cold_observable({
164 auto ys2 = sc.make_cold_observable({
171 auto ys3 = sc.make_cold_observable({
178 auto xs = sc.make_cold_observable({
251 auto ys1 = sc.make_cold_observable({
258 auto ys2 = sc.make_cold_observable({
265 auto ys3 = sc.make_cold_observable({
272 auto xs = sc.make_cold_observable({
[all …]
Damb_variadic.cpp178 auto ys1 = sc.make_cold_observable({
185 auto ys2 = sc.make_cold_observable({
192 auto ys3 = sc.make_cold_observable({
256 auto ys1 = sc.make_cold_observable({
263 auto ys2 = sc.make_cold_observable({
270 auto ys3 = sc.make_cold_observable({
334 auto ys1 = sc.make_cold_observable({
341 auto ys2 = sc.make_cold_observable({
348 auto ys3 = sc.make_cold_observable({
412 auto ys1 = sc.make_cold_observable({
[all …]
Dmerge_delay_error.cpp15 auto ys1 = sc.make_cold_observable({
25 auto ys2 = sc.make_cold_observable({
33 auto ys3 = sc.make_cold_observable({
125 auto ys1 = sc.make_cold_observable({
135 auto ys2 = sc.make_cold_observable({
144 auto ys3 = sc.make_cold_observable({
219 auto ys1 = sc.make_cold_observable({
230 auto ys2 = sc.make_cold_observable({
239 auto ys3 = sc.make_cold_observable({
Dswitch_on_next.cpp11 auto ys1 = sc.make_cold_observable({
21 auto ys2 = sc.make_cold_observable({
29 auto ys3 = sc.make_cold_observable({
115 auto ys1 = sc.make_cold_observable({
125 auto ys2 = sc.make_cold_observable({
133 auto ys3 = sc.make_cold_observable({
212 auto ys1 = sc.make_cold_observable({
222 auto ys2 = sc.make_cold_observable({
330 auto ys1 = sc.make_cold_observable({
Drepeat.cpp11 auto xs = sc.make_cold_observable({
65 auto xs = sc.make_cold_observable({
106 auto xs = sc.make_cold_observable({
152 auto xs = sc.make_cold_observable({
198 auto xs = sc.make_cold_observable({
252 auto xs = sc.make_cold_observable({
301 auto xs = sc.make_cold_observable({
347 auto xs = sc.make_cold_observable({
Dmerge.cpp100 auto ys1 = sc.make_cold_observable({
110 auto ys2 = sc.make_cold_observable({
118 auto ys3 = sc.make_cold_observable({
210 auto ys1 = sc.make_cold_observable({
220 auto ys2 = sc.make_cold_observable({
228 auto ys3 = sc.make_cold_observable({
Dswitch_if_empty.cpp10 auto ys = sc.make_cold_observable({
63 auto ys = sc.make_cold_observable({
118 auto ys = sc.make_cold_observable({
169 auto ys = sc.make_cold_observable({
223 auto ys = sc.make_cold_observable({
Dflat_map.cpp243 auto xs = sc.make_cold_observable({
251 auto ys = sc.make_cold_observable({
327 auto xs = sc.make_cold_observable({
335 auto ys = sc.make_cold_observable({
471 auto xs = sc.make_cold_observable({
480 auto ys = sc.make_cold_observable({
558 auto xs = sc.make_cold_observable({
568 auto ys = sc.make_cold_observable({
632 auto xs = sc.make_cold_observable({
640 auto ys = sc.make_cold_observable({
[all …]
Dconcat_map.cpp209 auto xs = sc.make_cold_observable({
215 auto ys = sc.make_cold_observable({
281 auto xs = sc.make_cold_observable({
287 auto ys = sc.make_cold_observable({
403 auto xs = sc.make_cold_observable({
409 auto ys = sc.make_cold_observable({
473 auto xs = sc.make_cold_observable({
479 auto ys = sc.make_cold_observable({
Don_error_resume_next.cpp23 auto ys = sc.make_cold_observable({
94 auto ys = sc.make_cold_observable({
167 auto ys = sc.make_cold_observable({
Dpairwise.cpp11 auto xs = sc.make_cold_observable({
54 auto xs = sc.make_cold_observable({
Dconcat.cpp100 auto ys1 = sc.make_cold_observable({
110 auto ys2 = sc.make_cold_observable({
118 auto ys3 = sc.make_cold_observable({
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-test.hpp156 …rxt::testable_observable<T> make_cold_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::de…
275 rxt::testable_observable<T> test_type::make_cold_observable(std::vector<rxn::recorded<std::shared_p… in make_cold_observable() function in rxcpp::schedulers::detail::test_type
586 …rxt::testable_observable<T> make_cold_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::de… in make_cold_observable() function in rxcpp::schedulers::test
587 return tester->make_cold_observable(std::move(messages)); in make_cold_observable()
591 auto make_cold_observable(const T (&arr) [size]) const in make_cold_observable() function in rxcpp::schedulers::test
592 -> decltype(tester->make_cold_observable(std::vector<T>())) { in make_cold_observable()
593 return tester->make_cold_observable(rxu::to_vector(arr)); in make_cold_observable()
597 auto make_cold_observable(std::initializer_list<T> il) const in make_cold_observable() function in rxcpp::schedulers::test
598 -> decltype(tester->make_cold_observable(std::vector<T>())) { in make_cold_observable()
599 return tester->make_cold_observable(std::vector<T>(il)); in make_cold_observable()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/
Dscope.cpp31 xs.reset(sc.make_cold_observable(msg)); in __anonbc61a3d20102()
150 xs.reset(sc.make_cold_observable(rxu::to_vector({ in __anonbc61a3d20902()
217 xs.reset(sc.make_cold_observable(rxu::to_vector({ in __anonbc61a3d20c02()
282 xs.reset(sc.make_cold_observable(rxu::to_vector({ in __anonbc61a3d20f02()
Ddefer.cpp26 xs.reset(sc.make_cold_observable({ in __anonf4110b5e0102()