Home
last modified time | relevance | path

Searched refs:synchronize_in_one_worker (Results 1 – 21 of 21) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dtimeout.cpp9 auto so = rx::synchronize_in_one_worker(sc);
50 auto so = rx::synchronize_in_one_worker(sc);
90 auto so = rx::synchronize_in_one_worker(sc);
134 auto so = rx::synchronize_in_one_worker(sc);
181 auto so = rx::synchronize_in_one_worker(sc);
Ddebounce.cpp9 auto so = rx::synchronize_in_one_worker(sc);
45 auto so = rx::synchronize_in_one_worker(sc);
85 auto so = rx::synchronize_in_one_worker(sc);
129 auto so = rx::synchronize_in_one_worker(sc);
176 auto so = rx::synchronize_in_one_worker(sc);
Ddelay.cpp9 auto so = rx::synchronize_in_one_worker(sc);
45 auto so = rx::synchronize_in_one_worker(sc);
85 auto so = rx::synchronize_in_one_worker(sc);
129 auto so = rx::synchronize_in_one_worker(sc);
Dbuffer.cpp475 auto so = rx::synchronize_in_one_worker(sc);
520 auto so = rx::synchronize_in_one_worker(sc);
564 auto so = rx::synchronize_in_one_worker(sc);
608 auto so = rx::synchronize_in_one_worker(sc);
652 auto so = rx::synchronize_in_one_worker(sc);
684 auto so = rx::synchronize_in_one_worker(sc);
741 auto so = rx::synchronize_in_one_worker(sc);
796 auto so = rx::synchronize_in_one_worker(sc);
854 auto so = rx::synchronize_in_one_worker(sc);
906 auto so = rx::synchronize_in_one_worker(sc);
[all …]
Dwindow.cpp309 auto so = rx::synchronize_in_one_worker(sc);
379 auto so = rx::synchronize_in_one_worker(sc);
442 auto so = rx::synchronize_in_one_worker(sc);
506 auto so = rx::synchronize_in_one_worker(sc);
565 auto so = rx::synchronize_in_one_worker(sc);
631 auto so = rx::synchronize_in_one_worker(sc);
691 auto so = rx::synchronize_in_one_worker(sc);
752 auto so = rx::synchronize_in_one_worker(sc);
814 auto so = rx::synchronize_in_one_worker(sc);
878 auto so = rx::synchronize_in_one_worker(sc);
[all …]
Dsample.cpp7 auto so = rx::synchronize_in_one_worker(sc);
61 auto so = rx::synchronize_in_one_worker(sc);
111 auto so = rx::synchronize_in_one_worker(sc);
Dtime_interval.cpp49 auto so = rx::synchronize_in_one_worker(sc);
93 auto so = rx::synchronize_in_one_worker(sc);
141 auto so = rx::synchronize_in_one_worker(sc);
Dtimestamp.cpp49 auto so = rx::synchronize_in_one_worker(sc);
93 auto so = rx::synchronize_in_one_worker(sc);
141 auto so = rx::synchronize_in_one_worker(sc);
Dwindow_toggle.cpp9 auto so = rx::synchronize_in_one_worker(sc);
89 auto so = rx::synchronize_in_one_worker(sc);
169 auto so = rx::synchronize_in_one_worker(sc);
248 auto so = rx::synchronize_in_one_worker(sc);
Dsubscribe_on.cpp95 auto so = rx::synchronize_in_one_worker(sc);
140 auto so = rx::synchronize_in_one_worker(sc);
Dobserve_on.cpp55 auto so = rx::synchronize_in_one_worker(sc);
100 auto so = rx::synchronize_in_one_worker(sc);
Dtake_last.cpp198 auto so = rx::synchronize_in_one_worker(sc);
237 auto so = rx::synchronize_in_one_worker(sc);
Dskip_last.cpp200 auto so = rx::synchronize_in_one_worker(sc);
239 auto so = rx::synchronize_in_one_worker(sc);
Dscan.cpp9 auto so = rxcpp::synchronize_in_one_worker(sc);
Damb_variadic.cpp557 auto so = rx::synchronize_in_one_worker(sc);
Dskip_until.cpp565 auto so = rx::synchronize_in_one_worker(sc);
Dtake_until.cpp749 auto so = rx::synchronize_in_one_worker(sc);
Damb.cpp913 auto so = rx::synchronize_in_one_worker(sc);
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-synchronize.hpp192 class synchronize_in_one_worker : public coordination_base class
236 explicit synchronize_in_one_worker(rxsc::scheduler sc) : factory(sc) {} in synchronize_in_one_worker() function in rxcpp::synchronize_in_one_worker
250 inline synchronize_in_one_worker synchronize_event_loop() { in synchronize_event_loop()
251 static synchronize_in_one_worker r(rxsc::make_event_loop()); in synchronize_event_loop()
255 inline synchronize_in_one_worker synchronize_new_thread() { in synchronize_new_thread()
256 static synchronize_in_one_worker r(rxsc::make_new_thread()); in synchronize_new_thread()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/
Dtimer.cpp9 auto so = rx::synchronize_in_one_worker(sc);
Dinterval.cpp74 auto so = rx::synchronize_in_one_worker(sc);