Searched refs:make_observer (Results 1 – 7 of 7) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observer.hpp | 459 auto make_observer() in make_observer() function
465 auto make_observer(observer<U, State, OnNext, OnError, OnCompleted> o) in make_observer() function
470 auto make_observer(Observer ob) in make_observer() function
479 auto make_observer(Observer ob) in make_observer() function
488 auto make_observer(OnNext on) in make_observer() function
496 auto make_observer(OnError oe) in make_observer() function
505 auto make_observer(OnNext on, OnError oe) in make_observer() function
514 auto make_observer(OnNext on, OnCompleted oc) in make_observer() function
523 auto make_observer(OnNext on, OnError oe, OnCompleted oc) in make_observer() function
535 auto make_observer(State os, OnNext on) in make_observer() function
[all …]
|
| D | rx-subscriber.hpp | 341 …bscriber<T, observer<T, Observer>>(trace_id::make_next_id_subscriber(), cs, make_observer<T>(o)); in make_subscriber()
562 …r<T, Observer>>(trace_id::make_next_id_subscriber(), scbr.get_subscription(), make_observer<T>(o)); in make_subscriber()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-tap.hpp | 54 …using out_type = decltype(make_observer<source_value_type, rxcpp::detail::OnErrorIgnore>(*((ArgN*)…
56 … return make_observer<source_value_type, rxcpp::detail::OnErrorIgnore>(std::forward<ArgN>(an)...); in operator ()()
|
| D | rx-observe_on.hpp | 216 return make_subscriber<value_type>(d, cs, make_observer<value_type>(std::move(o))); in make()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | observer.cpp | 65 auto so = rx::make_observer<int>(emptyNext);
66 auto eo = rx::make_observer<int>();
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/ |
| D | create.cpp | 58 rx::make_observer<int>(so.get_observer(), in __anon55f236ca0302()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/ |
| D | subject.cpp | 233 auto o = rx::make_observer<int>(
|