Home
last modified time | relevance | path

Searched refs:make_current_thread (Results 1 – 9 of 9) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/
Dinterval.cpp9 auto sc = rxsc::make_current_thread();
31 auto sc = rxsc::make_current_thread();
73 auto sc = rxsc::make_current_thread();
Dtimer.cpp8 auto sc = rxsc::make_current_thread();
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/
Dsubscription.cpp36 auto sc = rxsc::make_current_thread();
81 auto sc = rxsc::make_current_thread();
118 auto sc = rxsc::make_current_thread();
227 auto sc = rxsc::make_current_thread();
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dbuffer.cpp474 auto sc = rxsc::make_current_thread();
519 auto sc = rxsc::make_current_thread();
563 auto sc = rxsc::make_current_thread();
607 auto sc = rxsc::make_current_thread();
651 auto sc = rxsc::make_current_thread();
Dscan.cpp8 auto sc = rxsc::make_current_thread();
Dsequence_equal.cpp784 … .sequence_equal(ys, rxcpp::identity_one_worker(rxsc::make_current_thread())) in __anon811547631102()
839 …l(ys, [](int x, int y) { return x == y; }, rxcpp::identity_one_worker(rxsc::make_current_thread())) in __anon811547631202()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-currentthread.hpp263 inline const scheduler& make_current_thread() { in make_current_thread() function
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-coordination.hpp176 static identity_one_worker r(rxsc::make_current_thread()); in identity_current_thread()
Drx-observable.hpp518 const auto& sc = rxsc::make_current_thread(); in detail_subscribe()