Searched refs:innercs (Results 1 – 8 of 8) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-window_toggle.hpp | 113 composite_subscription innercs; in window_toggle_observer() local
117 auto innerscope = localState->dest.add(innercs); in window_toggle_observer()
119 innercs.add([=](){ in window_toggle_observer()
137 innercs, in window_toggle_observer()
145 composite_subscription innercs; in window_toggle_observer() local
149 auto innerscope = localState->dest.add(innercs); in window_toggle_observer()
151 innercs.add([=](){ in window_toggle_observer()
172 innercs, in window_toggle_observer()
174 [close, innercs](closings_value_type) { in window_toggle_observer()
176 innercs.unsubscribe(); in window_toggle_observer()
|
| D | rx-amb.hpp | 152 composite_subscription innercs; in on_subscribe() local
154 state->innerSubscriptions.push_back(innercs); in on_subscribe()
158 auto innercstoken = state->out.add(innercs); in on_subscribe()
160 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
172 innercs, in on_subscribe()
|
| D | rx-merge.hpp | 153 composite_subscription innercs; in on_subscribe() local
157 auto innercstoken = state->out.add(innercs); in on_subscribe()
159 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
170 innercs, in on_subscribe()
|
| D | rx-merge_delay_error.hpp | 147 composite_subscription innercs; in on_subscribe() local
151 auto innercstoken = state->out.add(innercs); in on_subscribe()
153 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
164 innercs, in on_subscribe()
|
| D | rx-flat_map.hpp | 176 composite_subscription innercs; in on_subscribe() local
180 auto innercstoken = state->out.add(innercs); in on_subscribe()
182 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
194 innercs, in on_subscribe()
|
| D | rx-combine_latest.hpp | 140 composite_subscription innercs; in subscribe_one() local
144 state->out.add(innercs); in subscribe_one()
158 innercs, in subscribe_one()
|
| D | rx-with_latest_from.hpp | 140 composite_subscription innercs; in subscribe_one() local
144 state->out.add(innercs); in subscribe_one()
158 innercs, in subscribe_one()
|
| D | rx-zip.hpp | 174 composite_subscription innercs; in subscribe_one() local
178 state->out.add(innercs); in subscribe_one()
192 innercs, in subscribe_one()
|