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