Searched refs:make_observer_dynamic (Results 1 – 7 of 7) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | subscription.cpp | 166 rx::make_observer_dynamic<int>( in __anon442cb92f0a02()
181 rx::make_observer_dynamic<int>( in __anon442cb92f0a02()
196 rx::make_observer_dynamic<int>( in __anon442cb92f0a02()
274 rx::make_observer_dynamic<int>( in __anon442cb92f1602()
288 rx::make_observer_dynamic<int>( in __anon442cb92f1602()
302 rx::make_observer_dynamic<int>( in __anon442cb92f1602()
|
| D | observer.cpp | 64 auto dob = rx::make_observer_dynamic<int>(emptyNext);
107 auto dob = rx::make_subscriber<int>(rx::make_observer_dynamic<int>(next, error, completed));
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-notification.hpp | 137 other->accept(make_subscriber<T>(make_observer_dynamic<T>([this, &result](T v) { in equals()
162 … other->accept(make_subscriber<T>(make_observer_dynamic<T>([](T){}, [&result](rxu::error_ptr){ in equals()
181 other->accept(make_subscriber<T>(make_observer_dynamic<T>([](T){}, [&result](){ in equals()
|
| D | rx-observer.hpp | 584 auto make_observer_dynamic(Observer o) in make_observer_dynamic() function
591 auto make_observer_dynamic(OnNext&& on) in make_observer_dynamic() function
599 auto make_observer_dynamic(OnNext&& on, OnError&& oe) in make_observer_dynamic() function
608 auto make_observer_dynamic(OnNext&& on, OnCompleted&& oc) in make_observer_dynamic() function
617 auto make_observer_dynamic(OnNext&& on, OnError&& oe, OnCompleted&& oc) in make_observer_dynamic() function
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | lift.cpp | 248 rx::make_observer_dynamic<int>( in __anon42c5b5c00602()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-synchronize.hpp | 137 auto o = make_subscriber<T>(dl, make_observer_dynamic<T>( *static_cast<base_type*>(this) )); in synchronize_observer()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-test.hpp | 195 return rxcpp::make_subscriber<T>(rxt::testable_observer<T>(ts, make_observer_dynamic<T>( in make_subscriber()
|