Home
last modified time | relevance | path

Searched refs:scbr (Results 1 – 14 of 14) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-subscriber.hpp520 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, in make_subscriber() argument
523 …auto r = subscriber<T, observer<T, I>>(trace_id::make_next_id_subscriber(), scbr.get_subscriptio… in make_subscriber()
524 trace_activity().connect(r, scbr); in make_subscriber()
528 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, in make_subscriber() argument
531 auto r = subscriber<T, observer<T, I>>(std::move(id), scbr.get_subscription(), o); in make_subscriber()
532 trace_activity().connect(r, scbr); in make_subscriber()
536 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const Observer& o) in make_subscriber() argument
540 auto r = subscriber<T, Observer>(std::move(id), scbr.get_subscription(), o); in make_subscriber()
541 trace_activity().connect(r, scbr); in make_subscriber()
545 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const Observer& o) in make_subscriber() argument
[all …]
Drx-observable.hpp185 auto scbr = make_subscriber<T>( in blocking_subscribe() local
199 auto cs = scbr.get_subscription(); in blocking_subscribe()
207 source.subscribe(std::move(scbr)); in blocking_subscribe()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/
Dsubject.cpp67 syncwithvoid::sync_subscriber<int, decltype(onnext)> scbr(onnext);
68 for (int i = 0; i < onnextcalls && scbr.is_subscribed(); i++) {
69 scbr.on_next(i);
152 asyncwithready::async_subscriber<int, decltype(onnext)> scbr(onnext);
155 chunk = [&chunk, scbr, i]() mutable { in __anon2b91aec50402()
156 for (; i < onnextcalls && scbr.is_subscribed(); i++) { in __anon2b91aec50402()
157 auto controller = scbr.on_next(i); in __anon2b91aec50402()
206 asyncwithfuture::async_subscriber<int, decltype(onnext)> scbr(onnext);
207 for (int i = 0; i < onnextcalls && scbr.is_subscribed(); i++) {
208 auto isready = scbr.on_next(i);
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-switch_on_next.hpp79 void on_subscribe(Subscriber scbr) const { in on_subscribe()
105 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
108 …auto state = std::make_shared<switch_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
Drx-merge.hpp100 void on_subscribe(Subscriber scbr) const { in on_subscribe()
125 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
128 … auto state = std::make_shared<merge_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
Drx-merge_delay_error.hpp93 void on_subscribe(Subscriber scbr) const { in on_subscribe()
119 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
122 … auto state = std::make_shared<merge_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
Drx-amb.hpp96 void on_subscribe(Subscriber scbr) const { in on_subscribe()
122 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
125 … auto state = std::make_shared<amb_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
Drx-concat.hpp96 void on_subscribe(Subscriber scbr) const { in on_subscribe()
177 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
180 …auto state = std::make_shared<concat_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
Drx-combine_latest.hpp201 void on_subscribe(Subscriber scbr) const { in on_subscribe()
228 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
231 …te = std::make_shared<combine_latest_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
Drx-with_latest_from.hpp201 void on_subscribe(Subscriber scbr) const { in on_subscribe()
228 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
231 … = std::make_shared<with_latest_from_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
Drx-zip.hpp233 void on_subscribe(Subscriber scbr) const { in on_subscribe()
260 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
263 … auto state = std::make_shared<zip_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
Drx-flat_map.hpp125 void on_subscribe(Subscriber scbr) const { in on_subscribe()
148 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
151 auto state = std::make_shared<state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
Drx-concat_map.hpp129 void on_subscribe(Subscriber scbr) const { in on_subscribe()
216 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
219 … state = std::make_shared<concat_map_state_type>(initial, std::move(coordinator), std::move(scbr)); in on_subscribe()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-synchronize.hpp96 … synchronize_observer_state(coordinator_type coor, composite_subscription cs, output_type scbr) in synchronize_observer_state()
100 , destination(std::move(scbr)) in synchronize_observer_state()