Searched refs:is_subscriber (Results 1 – 21 of 21) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-lift.hpp | 39 is_subscriber<detail_result>,
40 is_subscriber<for_type>,
|
| D | rx-switch_on_next.hpp | 80 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-merge.hpp | 101 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-merge_delay_error.hpp | 94 … static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-amb.hpp | 97 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-concat.hpp | 97 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-combine_latest.hpp | 202 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-with_latest_from.hpp | 202 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-zip.hpp | 234 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-flat_map.hpp | 126 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-concat_map.hpp | 130 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-subscriber.hpp | 27 static_assert(!is_subscriber<Observer>::value, "not allowed to nest subscribers");
141 static_assert(!is_subscriber<U>::value, "cannot nest subscribers"); in subscriber()
252 !is_subscriber<Observer>::value, in make_subscriber()
260 !is_subscriber<Observer>::value && in make_subscriber()
328 !is_subscriber<Observer>::value && in make_subscriber()
337 !is_subscriber<Observer>::value && in make_subscriber()
427 !is_subscriber<Observer>::value && in make_subscriber()
437 !is_subscriber<Observer>::value && in make_subscriber()
558 !is_subscriber<Observer>::value && in make_subscriber()
570 !is_subscriber<Observer>::value && in make_subscriber()
[all …]
|
| D | rx-coordination.hpp | 80 … is_subscriber<T>::value, get_subscriber<T>, not_supported>::type>::type>::type::type type;
103 static_assert(is_subscriber<Subscriber>::value, "can only synchronize subscribers"); in out()
|
| D | rx-test.hpp | 44 … static_assert(is_subscriber<Subscriber>::value, "on_subscribe must be passed a subscriber."); in on_subscribe()
|
| D | rx-predef.hpp | 115 class is_subscriber class
|
| D | rx-observable.hpp | 86 typename std::enable_if<is_subscriber<Subscriber>::value, void>::type
507 … static_assert(is_subscriber<subscriber_type>::value, "subscribe must be passed a subscriber"); in detail_subscribe()
|
| D | rx-observer.hpp | 653 …-> typename std::enable_if<is_subscriber<Subscriber>::value, typename detail::maybe_from_result<F… in on_exception()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-timer.hpp | 75 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-range.hpp | 66 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-interval.hpp | 72 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|
| D | rx-iterate.hpp | 90 static_assert(is_subscriber<Subscriber>::value, "subscribe must be passed a subscriber"); in on_subscribe()
|