Home
last modified time | relevance | path

Searched refs:source_lifetime (Results 1 – 10 of 10) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-retry-repeat-common.hpp24 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
Drx-take.hpp93 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()
Drx-take_last.hpp86 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()
Drx-subscribe_on.hpp88 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()
Drx-skip_last.hpp86 composite_subscription source_lifetime; in on_subscribe() local
88 s.add(source_lifetime); in on_subscribe()
92 source_lifetime, in on_subscribe()
Drx-skip.hpp94 composite_subscription source_lifetime; in on_subscribe() local
96 s.add(source_lifetime); in on_subscribe()
100 source_lifetime, in on_subscribe()
Drx-group_by.hpp110 : 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()
Drx-take_until.hpp110 out.add(source_lifetime); in on_subscribe()
114 composite_subscription source_lifetime; in on_subscribe() member
171 state->source_lifetime, in on_subscribe()
Drx-skip_until.hpp100 out.add(source_lifetime); in on_subscribe()
104 composite_subscription source_lifetime; in on_subscribe() member
168 state->source_lifetime, in on_subscribe()
Drx-sequence_equal.hpp95 out.add(source_lifetime); in on_subscribe()
99 composite_subscription source_lifetime; in on_subscribe() member
184 state->source_lifetime, in on_subscribe()