Searched refs:sourceLifetime (Results 1 – 2 of 2) sorted by relevance
108 , sourceLifetime(composite_subscription::empty()) in on_subscribe()156 } else if (!state->sourceLifetime.is_subscribed()) { in on_subscribe()170 composite_subscription sourceLifetime; in on_subscribe() member182 state->sourceLifetime = composite_subscription(); in on_subscribe()186 state->out.add(state->sourceLifetime); in on_subscribe()200 state->sourceLifetime, in on_subscribe()
140 , sourceLifetime(composite_subscription::empty()) in on_subscribe()196 } else if (!state->sourceLifetime.is_subscribed()) { in on_subscribe()209 composite_subscription sourceLifetime; in on_subscribe() member221 state->sourceLifetime = composite_subscription(); in on_subscribe()225 state->out.add(state->sourceLifetime); in on_subscribe()239 state->sourceLifetime, in on_subscribe()