Searched refs:issubscribed (Results 1 – 2 of 2) sorted by relevance
75 : issubscribed(initial) in base_subscription_state()81 std::atomic<bool> issubscribed; member in rxcpp::subscription::base_subscription_state97 if (issubscribed.exchange(false)) { in unsubscribe()176 return state->issubscribed; in is_subscribed()256 std::atomic<bool> issubscribed; member265 : issubscribed(true) in composite_subscription_state()269 : issubscribed(false) in composite_subscription_state()285 if (!issubscribed) { // load.acq [seq_cst] in add()289 if (!issubscribed) { // load.acq [seq_cst] in add()306 if (issubscribed) { // load.acq [seq_cst] in remove()[all …]
42 bool issubscribed; member in syncwithvoid::sync_subscriber45 , issubscribed(true) in sync_subscriber()48 bool is_subscribed() {return issubscribed;} in is_subscribed()49 void unsubscribe() {issubscribed = false;} in unsubscribe()103 bool issubscribed; member in asyncwithready::async_subscriber107 , issubscribed(true) in async_subscriber()111 bool is_subscribed() {return issubscribed;} in is_subscribed()112 void unsubscribe() {issubscribed = false;} in unsubscribe()180 bool issubscribed; member in asyncwithfuture::async_subscriber183 , issubscribed(true) in async_subscriber()[all …]