Home
last modified time | relevance | path

Searched refs:weak_subscription (Results 1 – 6 of 6) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-subscription.hpp245 typedef subscription::weak_state_type weak_subscription; typedef in rxcpp::detail::composite_subscription_inner
284 inline weak_subscription add(subscription s) { in add()
305 inline void remove(weak_subscription w) { in remove()
423 inline weak_subscription add(subscription s) const { in add()
429 inline void remove(weak_subscription w) const { in remove()
465 typedef subscription::weak_state_type weak_subscription; typedef in rxcpp::composite_subscription
508 inline weak_subscription add(subscription s) const { in add()
523 -> typename std::enable_if<detail::is_unsubscribe_function<F>::value, weak_subscription>::type { in add()
527 inline void remove(weak_subscription w) const { in remove()
558 typedef typename composite_subscription::weak_subscription weak_subscription; typedef in rxcpp::resource
[all …]
Drx-scheduler.hpp209 typedef composite_subscription::weak_subscription weak_subscription; typedef in rxcpp::schedulers::worker
237 inline weak_subscription add(subscription s) const { in add()
240 inline void remove(weak_subscription w) const { in remove()
434 composite_subscription::weak_subscription action_scope;
504 typedef composite_subscription::weak_subscription weak_subscription; typedef in rxcpp::schedulers::schedulable
541 , action_scope(scbl.scoped ? controller.lock().add(lifetime) : weak_subscription()) in schedulable()
595 inline weak_subscription add(subscription s) const { in add()
600 …-> typename std::enable_if<rxcpp::detail::is_unsubscribe_function<F>::value, weak_subscription>::t… in add()
603 inline void remove(weak_subscription w) const { in remove()
Drx-subscriber.hpp105 typedef typename composite_subscription::weak_subscription weak_subscription; typedef in rxcpp::subscriber
203 weak_subscription add(subscription s) const { in add()
208 -> typename std::enable_if<detail::is_unsubscribe_function<F>::value, weak_subscription>::type { in add()
211 void remove(weak_subscription w) const { in remove()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-retry-repeat-common.hpp57 composite_subscription::weak_subscription lifetime_token;
Drx-multicast.hpp50 rxu::detail::maybe<typename composite_subscription::weak_subscription> connection;
Drx-group_by.hpp105 typedef std::vector<typename composite_subscription::weak_subscription> bindings_type;