Lines Matching refs:issubscribed
75 : issubscribed(initial) in base_subscription_state()
81 std::atomic<bool> issubscribed; member in rxcpp::subscription::base_subscription_state
97 if (issubscribed.exchange(false)) { in unsubscribe()
176 return state->issubscribed; in is_subscribed()
256 std::atomic<bool> issubscribed; member
265 : 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()
317 if (issubscribed) { // load.acq [seq_cst] in remove()
335 if (issubscribed) { // load.acq [seq_cst] in clear()
338 if (!issubscribed) { // load.acq [seq_cst] in clear()
367 if (issubscribed.exchange(false)) { // cas.acq_rel [seq_cst] in unsubscribe()