| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| rx-sameworker.hpp | 37 auto inner_lifetime = controller.get_subscription();
|
| rx-runloop.hpp | 162 composite_subscription get_subscription() const { function in class:rxcpp::schedulers::run_loop
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| rx-behavior.hpp | 53 return make_subscriber<T>(this->get_id(), this->get_subscription(), observer<T, detail::behavior_observer<T>>(*this)).as_dynamic();
95 if (keepAlive.get_subscription().is_subscribed()) {
|
| rx-subject.hpp | 121 composite_subscription get_subscription() const { function in class:rxcpp::subjects::detail::multicast_observer
125 return make_subscriber<T>(get_id(), get_subscription(), observer<T, detail::multicast_observer<T>>(*this));
257 composite_subscription get_subscription() const { function in class:rxcpp::subjects::subject
258 return s.get_subscription();
|
| rx-replaysubject.hpp | 107 return make_subscriber<T>(this->get_id(), this->get_subscription(), observer<T, detail::replay_observer<T, Coordination>>(*this)).as_dynamic();
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| rx-subscriber.hpp | 159 const composite_subscription& get_subscription() const { function in class:rxcpp::subscriber
162 composite_subscription& get_subscription() { function in class:rxcpp::subscriber
523 auto r = subscriber<T, observer<T, I>>(trace_id::make_next_id_subscriber(), scbr.get_subscription(), o);
531 auto r = subscriber<T, observer<T, I>>(std::move(id), scbr.get_subscription(), o);
540 auto r = subscriber<T, Observer>(std::move(id), scbr.get_subscription(), o);
550 auto r = subscriber<T, Observer>(trace_id::make_next_id_subscriber(), scbr.get_subscription(), o);
562 auto r = subscriber<T, observer<T, Observer>>(trace_id::make_next_id_subscriber(), scbr.get_subscription(), make_observer<T>(o));
574 auto r = subscriber<T, observer<T, Observer>>(std::move(id), scbr.get_subscription(), o);
583 auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>(trace_id::make_next_id_subscriber(), scbr.get_subscription(),
593 auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>(std::move(id), scbr.get_subscription(),
[all...] |
| rx-scheduler.hpp | 225 inline const composite_subscription& get_subscription() const { function in class:rxcpp::schedulers::worker
228 inline composite_subscription& get_subscription() { function in class:rxcpp::schedulers::worker
520 : lifetime(q.get_subscription())
537 : lifetime(scbl.get_subscription())
545 inline const composite_subscription& get_subscription() const { function in class:rxcpp::schedulers::schedulable
548 inline composite_subscription& get_subscription() { function in class:rxcpp::schedulers::schedulable
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| rx-finally.hpp | 81 auto dl = d.get_subscription();
|
| rx-pairwise.hpp | 78 auto cs = d.get_subscription();
|
| rx-buffer_count.hpp | 119 auto cs = d.get_subscription();
|
| rx-map.hpp | 88 auto cs = d.get_subscription();
|
| rx-subscribe_on.hpp | 104 auto ol = state->out.get_subscription();
|
| rx-window.hpp | 121 auto cs = d.get_subscription();
|
| rx-switch_on_next.hpp | 105 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription());
|
| rx-amb.hpp | 122 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription());
|
| rx-concat.hpp | 177 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription());
|
| rx-merge.hpp | 125 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription());
|
| rx-merge_delay_error.hpp | 119 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription());
|
| rx-observe_on.hpp | 206 auto coor = cn.create_coordinator(d.get_subscription());
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| rx-scope.hpp | 96 state->out.add(state->resource->get_subscription());
|
| rx-timer.hpp | 78 auto coordinator = initial.coordination.create_coordinator(o.get_subscription());
|
| rx-error.hpp | 68 auto coordinator = initial.coordination.create_coordinator(o.get_subscription());
|
| rx-interval.hpp | 75 auto coordinator = initial.coordination.create_coordinator(o.get_subscription());
|
| rx-range.hpp | 69 auto coordinator = initial.coordination.create_coordinator(o.get_subscription());
|
| rx-iterate.hpp | 117 auto coordinator = initial.coordination.create_coordinator(o.get_subscription());
|
