/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
rx-test.hpp | 56 typedef observer<T> observer_base; typedef in class:rxcpp::test::testable_observer 63 testable_observer(test_subject ts, observer_base ob) 64 : observer_base(std::move(ob))
|
rx-observer.hpp | 14 struct observer_base struct in namespace:rxcpp 179 class observer : public observer_base<T> 270 class observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted> : public observer_base<T> 393 class observer<T, void, void, void, void> : public observer_base<T> 400 using base_type = observer_base<T>;
|
rx-subscriber.hpp | 13 struct subscriber_base : public observer_base<T>, public subscription_base [all...] |
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
lift.cpp | 17 struct filter_observer : public rx::observer_base<typename std::decay<Subscriber>::type::value_type> 20 typedef rx::observer_base<typename std::decay<Subscriber>::type::value_type> base_type;
|