Searched refs:do_unsubscribe (Results 1 – 2 of 2) sorted by relevance
178 auto do_unsubscribe = [](composite_subscription cs) { in on_subscribe() local181 …state->innerSubscriptions.begin(), state->innerSubscriptions.begin() + current_id, do_unsubscribe); in on_subscribe()182 …ate->innerSubscriptions.begin() + current_id + 1, state->innerSubscriptions.end(), do_unsubscribe); in on_subscribe()
41 if (do_unsubscribe) { in ~nextdetacher()47 , do_unsubscribe(true) in nextdetacher()55 do_unsubscribe = false; in operator ()()64 volatile bool do_unsubscribe; member