Searched refs:subscriber_type (Results 1 – 4 of 4) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-subject.hpp | 242 typedef subscriber<T, observer<T, detail::multicast_observer<T>>> subscriber_type; typedef in rxcpp::subjects::subject
261 subscriber_type get_subscriber() const { in get_subscriber()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-test.hpp | 519 typedef subscriber<value_type, rxt::testable_observer<value_type>> subscriber_type; typedef
524 …std::enable_if<detail::is_create_source_function<F>::value, start_traits<F>>::type::subscriber_type in start()
531 …std::enable_if<detail::is_create_source_function<F>::value, start_traits<F>>::type::subscriber_type in start()
538 …std::enable_if<detail::is_create_source_function<F>::value, start_traits<F>>::type::subscriber_type in start()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observable.hpp | 505 typedef rxu::decay_t<Subscriber> subscriber_type; in detail_subscribe() typedef
507 … static_assert(is_subscriber<subscriber_type>::value, "subscribe must be passed a subscriber"); in detail_subscribe()
508 …ator_type::value_type, T>::value && std::is_convertible<T*, typename subscriber_type::value_type*>… in detail_subscribe()
509 …static_assert(detail::has_on_subscribe_for<subscriber_type, source_operator_type>::value, "inner m… in detail_subscribe()
518 … detail::safe_subscriber<source_operator_type, subscriber_type> subscriber(source_operator, o); in detail_subscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-group_by.hpp | 87 …typedef std::map<key_type, typename subject_type::subscriber_type, predicate_type> key_subscriber_…
|