Home
last modified time | relevance | path

Searched refs:innercstoken (Results 1 – 6 of 6) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-merge.hpp157 auto innercstoken = state->out.add(innercs); in on_subscribe() local
159 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
160 state->out.remove(innercstoken); in on_subscribe()
Drx-merge_delay_error.hpp151 auto innercstoken = state->out.add(innercs); in on_subscribe() local
153 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
154 state->out.remove(innercstoken); in on_subscribe()
Drx-amb.hpp158 auto innercstoken = state->out.add(innercs); in on_subscribe() local
160 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
161 state->out.remove(innercstoken); in on_subscribe()
Drx-concat.hpp123 auto innercstoken = state->out.add(collectionLifetime); in on_subscribe() local
125 collectionLifetime.add(make_subscription([state, innercstoken](){ in on_subscribe()
126 state->out.remove(innercstoken); in on_subscribe()
Drx-flat_map.hpp180 auto innercstoken = state->out.add(innercs); in on_subscribe() local
182 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
183 state->out.remove(innercstoken); in on_subscribe()
Drx-concat_map.hpp162 auto innercstoken = state->out.add(collectionLifetime); in on_subscribe() local
164 collectionLifetime.add(make_subscription([state, innercstoken](){ in on_subscribe()
165 state->out.remove(innercstoken); in on_subscribe()