Searched refs:collectionLifetime (Results 1 – 2 of 2) sorted by relevance
109 , collectionLifetime(composite_subscription::empty()) in on_subscribe()119 collectionLifetime = composite_subscription(); in on_subscribe()123 auto innercstoken = state->out.add(collectionLifetime); in on_subscribe()125 collectionLifetime.add(make_subscription([state, innercstoken](){ in on_subscribe()140 collectionLifetime, in on_subscribe()154 state->collectionLifetime.unsubscribe(); in on_subscribe()171 composite_subscription collectionLifetime; in on_subscribe() member203 if (state->collectionLifetime.is_subscribed()) { in on_subscribe()215 … if (!state->collectionLifetime.is_subscribed() && state->selectedCollections.empty()) { in on_subscribe()
141 , collectionLifetime(composite_subscription::empty()) in on_subscribe()158 collectionLifetime = composite_subscription(); in on_subscribe()162 auto innercstoken = state->out.add(collectionLifetime); in on_subscribe()164 collectionLifetime.add(make_subscription([state, innercstoken](){ in on_subscribe()179 collectionLifetime, in on_subscribe()194 state->collectionLifetime.unsubscribe(); in on_subscribe()210 composite_subscription collectionLifetime; in on_subscribe() member242 if (state->collectionLifetime.is_subscribed()) { in on_subscribe()254 … if (!state->collectionLifetime.is_subscribed() && state->selectedCollections.empty()) { in on_subscribe()