Searched refs:innercstoken (Results 1 – 6 of 6) sorted by relevance
157 auto innercstoken = state->out.add(innercs); in on_subscribe() local159 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()160 state->out.remove(innercstoken); in on_subscribe()
151 auto innercstoken = state->out.add(innercs); in on_subscribe() local153 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()154 state->out.remove(innercstoken); in on_subscribe()
158 auto innercstoken = state->out.add(innercs); in on_subscribe() local160 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()161 state->out.remove(innercstoken); in on_subscribe()
123 auto innercstoken = state->out.add(collectionLifetime); in on_subscribe() local125 collectionLifetime.add(make_subscription([state, innercstoken](){ in on_subscribe()126 state->out.remove(innercstoken); in on_subscribe()
180 auto innercstoken = state->out.add(innercs); in on_subscribe() local182 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()183 state->out.remove(innercstoken); in on_subscribe()
162 auto innercstoken = state->out.add(collectionLifetime); in on_subscribe() local164 collectionLifetime.add(make_subscription([state, innercstoken](){ in on_subscribe()165 state->out.remove(innercstoken); in on_subscribe()