Searched refs:source_lifetime (Results 1 – 10 of 10) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-retry-repeat-common.hpp | 24 source_lifetime(composite_subscription::empty()), in state_type()
32 state->source_lifetime.unsubscribe(); in do_subscribe()
34 state->source_lifetime = composite_subscription(); in do_subscribe()
35 state->lifetime_token = state->out.add(state->source_lifetime); in do_subscribe()
39 state->source_lifetime, in do_subscribe()
55 composite_subscription source_lifetime; member
|
| D | rx-take.hpp | 93 composite_subscription source_lifetime; in on_subscribe() local
95 s.add(source_lifetime); in on_subscribe()
99 source_lifetime, in on_subscribe()
101 [state, source_lifetime](T t) { in on_subscribe()
109 source_lifetime.unsubscribe(); in on_subscribe()
|
| D | rx-take_last.hpp | 86 composite_subscription source_lifetime; in on_subscribe() local
88 s.add(source_lifetime); in on_subscribe()
92 source_lifetime, in on_subscribe()
94 [state, source_lifetime](T t) { in on_subscribe()
|
| D | rx-subscribe_on.hpp | 88 composite_subscription source_lifetime; in on_subscribe() member
103 auto sl = state->source_lifetime; in on_subscribe()
118 state->source_lifetime.add([=](){ in on_subscribe()
129 state->source.subscribe(state->source_lifetime, state->out); in on_subscribe()
|
| D | rx-skip.hpp | 94 composite_subscription source_lifetime; in on_subscribe() local
96 s.add(source_lifetime); in on_subscribe()
100 source_lifetime, in on_subscribe()
|
| D | rx-skip_last.hpp | 86 composite_subscription source_lifetime; in on_subscribe() local
88 s.add(source_lifetime); in on_subscribe()
92 source_lifetime, in on_subscribe()
|
| D | rx-group_by.hpp | 110 : source_lifetime(sl) in group_by_state_type()
114 composite_subscription source_lifetime; member
124 if (!state->source_lifetime.is_subscribed()) { in stopsource()
129 state->source_lifetime.unsubscribe(); in stopsource()
225 auto ssub = state->source_lifetime.add(duration_sub); in on_next()
235 expire_state->source_lifetime.remove(ssub); in on_next()
|
| D | rx-take_until.hpp | 110 out.add(source_lifetime); in on_subscribe()
114 composite_subscription source_lifetime; in on_subscribe() member
171 state->source_lifetime, in on_subscribe()
|
| D | rx-skip_until.hpp | 100 out.add(source_lifetime); in on_subscribe()
104 composite_subscription source_lifetime; in on_subscribe() member
168 state->source_lifetime, in on_subscribe()
|
| D | rx-sequence_equal.hpp | 95 out.add(source_lifetime); in on_subscribe()
99 composite_subscription source_lifetime; in on_subscribe() member
184 state->source_lifetime, in on_subscribe()
|