Searched refs:inner_lifetime (Results 1 – 2 of 2) sorted by relevance
37 auto inner_lifetime = controller.get_subscription(); in create_worker() local38 auto token = inner_lifetime.add(cs); in create_worker()39 cs.add([inner_lifetime, token](){inner_lifetime.remove(token);}); in create_worker()
101 composite_subscription inner_lifetime; in on_subscribe() member133 state->inner_lifetime.unsubscribe(); in on_subscribe()135 state->inner_lifetime = composite_subscription(); in on_subscribe()139 auto innerlifetimetoken = state->out.add(state->inner_lifetime); in on_subscribe()141 state->inner_lifetime.add(make_subscription([state, innerlifetimetoken](){ in on_subscribe()152 state->inner_lifetime, in on_subscribe()