Lines Matching refs:subscription

67 class subscription : public subscription_base  class
109 friend bool operator<(const subscription&, const subscription&);
110 friend bool operator==(const subscription&, const subscription&);
113 subscription(weak_state_type w) in subscription() function in rxcpp::subscription
121 explicit subscription(std::shared_ptr<base_subscription_state> s) in subscription() function in rxcpp::subscription
130 subscription() in subscription() function in rxcpp::subscription
138 …explicit subscription(U u, typename std::enable_if<!is_subscription<U>::value, void**>::type = nul… in subscription() function in rxcpp::subscription
146 …explicit subscription(U u, typename std::enable_if<!std::is_same<subscription, U>::value && is_sub… in subscription() function in rxcpp::subscription
148 : state(std::move((*static_cast<subscription*>(&u)).state)) in subscription()
154 subscription(const subscription& o) in subscription() function in rxcpp::subscription
161 subscription(subscription&& o) in subscription() function in rxcpp::subscription
168 subscription& operator=(subscription o) { in operator =()
192 static subscription lock(weak_state_type w) { in lock()
193 return subscription(w); in lock()
198 static rxu::maybe<subscription> maybe_lock(weak_state_type w) { in maybe_lock()
201 return rxu::detail::maybe<subscription>{}; in maybe_lock()
203 return rxu::detail::maybe<subscription>{subscription{std::move(strong_subscription)}}; in maybe_lock()
208 inline bool operator<(const subscription& lhs, const subscription& rhs) { in operator <()
211 inline bool operator==(const subscription& lhs, const subscription& rhs) { in operator ==()
214 inline bool operator!=(const subscription& lhs, const subscription& rhs) { in operator !=()
220 -> subscription { in make_subscription()
221 return subscription(); in make_subscription()
226 subscription>::type { in make_subscription()
227 return subscription(std::forward<I>(i)); in make_subscription()
232 subscription>::type { in make_subscription()
233 return subscription(static_subscription<Unsubscribe>(std::forward<Unsubscribe>(u))); in make_subscription()
245 typedef subscription::weak_state_type weak_subscription;
249 std::set<subscription> subscriptions;
284 inline weak_subscription add(subscription s) { in add()
307 rxu::maybe<subscription> maybe_subscription = subscription::maybe_lock(w); in remove()
318 subscription& s = maybe_subscription.get(); in remove()
343 std::set<subscription> v(std::move(subscriptions)); in clear()
347 [](const subscription& s) { in clear()
373 std::set<subscription> v(std::move(subscriptions)); in unsubscribe()
377 [](const subscription& s) { in unsubscribe()
423 inline weak_subscription add(subscription s) const { in add()
461 , public subscription
465 typedef subscription::weak_state_type weak_subscription;
469 , subscription() // use empty base in composite_subscription()
477 , subscription(*static_cast<const inner_type*>(this)) in composite_subscription()
483 , subscription(static_cast<const subscription&>(o)) in composite_subscription()
488 , subscription(std::move(static_cast<subscription&>(o))) in composite_subscription()
495 subscription::operator=(std::move(*static_cast<subscription*>(&o))); in operator =()
503 using subscription::is_subscribed;
504 using subscription::unsubscribe;
508 inline weak_subscription add(subscription s) const { in add()
509 if (s == static_cast<const subscription&>(*this)) { in add()
514 auto that = this->subscription::state.get(); in add()
528 auto that = this->subscription::state.get(); in remove()
536 return static_cast<const subscription&>(lhs) < static_cast<const subscription&>(rhs); in operator <()
539 return static_cast<const subscription&>(lhs) == static_cast<const subscription&>(rhs); in operator ==()
588 weak_subscription add(subscription s) const { in add()