Searched defs:composite_subscription_state (Results 1 – 1 of 1) sorted by relevance
246 …struct composite_subscription_state : public std::enable_shared_from_this<composite_subscription_s… struct in rxcpp::detail::composite_subscription_inner249 std::set<subscription> subscriptions;254 std::mutex lock;256 std::atomic<bool> issubscribed;258 ~composite_subscription_state() in ~composite_subscription_state()264 composite_subscription_state() in composite_subscription_state() function268 composite_subscription_state(tag_composite_subscription_empty) in composite_subscription_state() function284 inline weak_subscription add(subscription s) { in add()305 inline void remove(weak_subscription w) { in remove()334 inline void clear() { in clear()[all …]