Home
last modified time | relevance | path

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

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-subscribe_on.hpp45 struct subscribe_on : public operator_base<T> struct
67 ~subscribe_on() in ~subscribe_on() argument
70 subscribe_on(source_type s, coordination_type sf) in subscribe_on() function
142 subscribe_on& operator=(subscribe_on o) RXCPP_DELETE;
150 auto subscribe_on(AN&&... an) in subscribe_on() function
165 …class SubscribeOn = rxo::detail::subscribe_on<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<…
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
Drange.cpp41 subscribe_on(rxcpp::observe_on_new_thread()).
107 subscribe_on(threads).
112 subscribe_on(threads).
134 subscribe_on(threads).
138 subscribe_on(threads).
Dsubscribe_on.cpp17 subscribe_on(rxcpp::synchronize_new_thread()).
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dsubscribe_on.cpp37 .subscribe_on(rx::observe_on_event_loop())
79 subscribe_on(rx::observe_on_event_loop()).
111 .subscribe_on(so); in __anon3bdb39080502()
156 | rxo::subscribe_on(so); in __anon3bdb39080602()
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/stop/
Dmain.cpp26 .subscribe_on(rx::observe_on_new_thread()) in main()
39 .subscribe_on(rx::observe_on_new_thread()) in main()
/external/Reactive-Extensions/RxCpp/projects/doxygen/
DCMakeLists.txt101 ${DOXY_EXAMPLES_SRC_DIR}/subscribe_on.cpp
/external/Reactive-Extensions/RxCpp/Rx/v2/test/
DCMakeLists.txt74 ${TEST_DIR}/operators/subscribe_on.cpp
/external/Reactive-Extensions/RxCpp/
DDeveloperManual.md19 All the operators that take multiple streams or deal in time (even ```subscribe_on``` and ```observ…
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-observable.hpp1189 auto subscribe_on(AN&&... an) const in subscribe_on() function in rxcpp::observable