| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | replay.cpp | 35 auto worker = coordination.create_coordinator().get_worker();
92 auto worker = coordination.create_coordinator().get_worker();
149 auto worker = coordination.create_coordinator().get_worker();
206 auto worker = coordination.create_coordinator().get_worker();
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-synchronize.hpp | 140 auto coordinator = cn.create_coordinator(dl); in synchronize_observer()
244 …inline coordinator_type create_coordinator(composite_subscription cs = composite_subscription()) c… in create_coordinator() function in rxcpp::synchronize_in_one_worker
|
| D | rx-replaysubject.hpp | 102 auto coordinator = coordination.create_coordinator(replayLifetime); in replay_observer()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-coordination.hpp | 164 …inline coordinator_type create_coordinator(composite_subscription cs = composite_subscription()) c… in create_coordinator() function in rxcpp::identity_one_worker
293 …inline coordinator_type create_coordinator(composite_subscription cs = composite_subscription()) c… in create_coordinator() function in rxcpp::serialize_one_worker
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-observe_on.hpp | 206 auto coor = cn.create_coordinator(d.get_subscription()); in make()
313 …inline coordinator_type create_coordinator(composite_subscription cs = composite_subscription()) c… in create_coordinator() function in rxcpp::observe_on_one_worker
|
| D | rx-subscribe_on.hpp | 96 auto coordinator = initial.coordination.create_coordinator(coordinator_lifetime); in on_subscribe()
|
| 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-delay.hpp | 164 auto coordinator = v.coordination.create_coordinator(); in make()
|
| 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-skip_until.hpp | 109 auto coordinator = initial.coordination.create_coordinator(); in on_subscribe()
|
| D | rx-concat.hpp | 177 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-sample_time.hpp | 183 auto coordinator = v.coordination.create_coordinator(); in make()
|
| D | rx-buffer_time_count.hpp | 212 auto coordinator = v.coordination.create_coordinator(); in make()
|
| D | rx-sequence_equal.hpp | 109 auto coordinator = initial.coordination.create_coordinator(); in on_subscribe()
|
| D | rx-with_latest_from.hpp | 228 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| 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()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | subscription.cpp | 156 auto ew = es.create_coordinator().get_worker(); in __anonfe564e910a02()
265 auto ew = es.create_coordinator().get_worker(); in __anonfe564e911602()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | group_by.cpp | 29 …read = rxcpp::observe_on_one_worker(rxcpp::observe_on_new_thread().create_coordinator().get_schedu…
54 …read = rxcpp::observe_on_one_worker(rxcpp::observe_on_new_thread().create_coordinator().get_schedu… in __anon769080da0502()
|