Searched refs:observe_on_one_worker (Results 1 – 3 of 3) sorted by relevance
261 class observe_on_one_worker : public coordination_base class305 explicit observe_on_one_worker(rxsc::scheduler sc) : factory(sc) {} in observe_on_one_worker() function in rxcpp::observe_on_one_worker319 inline observe_on_one_worker observe_on_run_loop(const rxsc::run_loop& rl) { in observe_on_run_loop()320 return observe_on_one_worker(rxsc::make_run_loop(rl)); in observe_on_run_loop()323 inline observe_on_one_worker observe_on_event_loop() { in observe_on_event_loop()324 static observe_on_one_worker r(rxsc::make_event_loop()); in observe_on_event_loop()328 inline observe_on_one_worker observe_on_new_thread() { in observe_on_new_thread()329 static observe_on_one_worker r(rxsc::make_new_thread()); in observe_on_new_thread()
29 …auto outputthread = rxcpp::observe_on_one_worker(rxcpp::observe_on_new_thread().create_coordinator…54 …auto producerthread = rxcpp::observe_on_one_worker(rxcpp::observe_on_new_thread().create_coordinat… in __anon39cb25110502()
150 auto so = rx::observe_on_one_worker(sc);