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_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-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-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()
|