| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | replay.cpp | 34 auto coordination = rxcpp::serialize_new_thread(); variable
35 auto worker = coordination.create_coordinator().get_worker();
38 replay(coordination);
48 …worker.schedule(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::… in __anon982cbcb50902()
91 auto coordination = rxcpp::serialize_new_thread(); variable
92 auto worker = coordination.create_coordinator().get_worker();
95 replay(2, coordination);
105 …worker.schedule(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::… in __anon982cbcb51502()
148 auto coordination = rxcpp::serialize_new_thread(); variable
149 auto worker = coordination.create_coordinator().get_worker();
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-timestamp.hpp | 49 : coordination(c) in timestamp_values()
53 coordination_type coordination; member
57 timestamp(coordination_type coordination) in timestamp()
58 : initial(coordination) in timestamp()
72 timestamp_observer(dest_type d, coordination_type coordination) in timestamp_observer()
74 coord(std::move(coordination)) in timestamp_observer()
89 return make_subscriber<value_type>(d, this_type(d, v.coordination)); in make()
|
| D | rx-time_interval.hpp | 50 : coordination(c) in time_interval_values()
54 coordination_type coordination; member
58 time_interval(coordination_type coordination) in time_interval()
59 : initial(coordination) in time_interval()
75 time_interval_observer(dest_type d, coordination_type coordination) in time_interval_observer()
77 coord(std::move(coordination)), in time_interval_observer()
95 return make_subscriber<value_type>(d, this_type(d, v.coordination)); in make()
|
| D | rx-observe_on.hpp | 52 coordination_type coordination; member
55 : coordination(std::move(cn)) in observe_on()
222 …decltype(observe_on_observer<decltype(dest.as_dynamic())>::make(dest.as_dynamic(), coordination)) { in operator ()()
223 …eturn observe_on_observer<decltype(dest.as_dynamic())>::make(dest.as_dynamic(), coordination); in operator ()()
269 identity_one_worker coordination; member in rxcpp::observe_on_one_worker::input_type
274 , coordination(factory) in input_type()
288 -> decltype(o.observe_on(coordination)) { in in()
289 return o.observe_on(coordination); in in()
|
| D | rx-sample_time.hpp | 55 , coordination(c) in sample_with_time_value()
59 coordination_type coordination; member
63 sample_with_time(duration_type period, coordination_type coordination) in sample_with_time()
64 : initial(period, coordination) in sample_with_time()
183 auto coordinator = v.coordination.create_coordinator(); in make()
|
| D | rx-delay.hpp | 55 , coordination(c) in delay_values()
59 coordination_type coordination; member
63 delay(duration_type period, coordination_type coordination) in delay()
64 : initial(period, coordination) in delay()
164 auto coordinator = v.coordination.create_coordinator(); in make()
|
| D | rx-window_time_count.hpp | 62 , coordination(c) in window_with_time_or_count_values()
67 coordination_type coordination; member
71 window_with_time_or_count(duration_type period, int count, coordination_type coordination) in window_with_time_or_count()
72 : initial(period, count, coordination) in window_with_time_or_count()
218 auto coordinator = v.coordination.create_coordinator(); in make()
|
| D | rx-timeout.hpp | 63 , coordination(c) in timeout_values()
68 coordination_type coordination; member
72 timeout(duration_type period, coordination_type coordination) in timeout()
73 : initial(period, coordination) in timeout()
211 auto coordinator = v.coordination.create_coordinator(); in make()
|
| D | rx-buffer_time_count.hpp | 62 , coordination(c) in buffer_with_time_or_count_values()
67 coordination_type coordination; member
71 buffer_with_time_or_count(duration_type period, int count, coordination_type coordination) in buffer_with_time_or_count()
72 : initial(period, count, coordination) in buffer_with_time_or_count()
212 auto coordinator = v.coordination.create_coordinator(); in make()
|
| D | rx-debounce.hpp | 55 , coordination(c) in debounce_values()
60 coordination_type coordination; member
64 debounce(duration_type period, coordination_type coordination) in debounce()
65 : initial(period, coordination) in debounce()
195 auto coordinator = v.coordination.create_coordinator(); in make()
|
| D | rx-subscribe_on.hpp | 57 , coordination(std::move(sf)) in subscribe_on_values()
61 coordination_type coordination; member
96 auto coordinator = initial.coordination.create_coordinator(coordinator_lifetime); in on_subscribe()
|
| D | rx-window_toggle.hpp | 68 , coordination(c) in window_toggle_values()
73 coordination_type coordination; member
77 window_toggle(openings_type opens, closing_selector_type closes, coordination_type coordination) in window_toggle()
78 : initial(opens, closes, coordination) in window_toggle()
257 auto coordinator = v.coordination.create_coordinator(d.get_subscription()); in make()
|
| D | rx-window_time.hpp | 72 , coordination(c) in window_with_time_values()
77 coordination_type coordination; member
81 window_with_time(duration_type period, duration_type skip, coordination_type coordination) in window_with_time()
82 : initial(period, skip, coordination) in window_with_time()
234 auto coordinator = v.coordination.create_coordinator(); in make()
|
| D | rx-buffer_time.hpp | 80 , coordination(c) in buffer_with_time_values()
85 coordination_type coordination; member
89 buffer_with_time(duration_type period, duration_type skip, coordination_type coordination) in buffer_with_time()
90 : initial(period, skip, coordination) in buffer_with_time()
238 auto coordinator = v.coordination.create_coordinator(); in make()
|
| D | rx-switch_on_next.hpp | 65 , coordination(std::move(sf)) in values()
69 coordination_type coordination; member
105 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
|
| D | rx-merge.hpp | 86 , coordination(std::move(sf)) in values()
90 coordination_type coordination; member
125 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
|
| D | rx-amb.hpp | 82 , coordination(std::move(sf)) in values()
86 coordination_type coordination; member
122 auto coordinator = initial.coordination.create_coordinator(scbr.get_subscription()); in on_subscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-replaysubject.hpp | 48 mutable coordination_type coordination; member in rxcpp::subjects::detail::replay_observer::replay_observer_state
67 , coordination(std::move(_coordination)) in replay_observer_state()
81 auto now = coordination.now(); in add()
98 …replay_observer(count_type count, period_type period, coordination_type coordination, composite_su… in replay_observer() argument
102 auto coordinator = coordination.create_coordinator(replayLifetime); in replay_observer()
103 …replay_observer_state>(std::move(count), std::move(period), std::move(coordination), std::move(coo… in replay_observer()
|
| D | rx-synchronize.hpp | 200 identity_one_worker coordination; member in rxcpp::synchronize_in_one_worker::input_type
205 , coordination(factory) in input_type()
219 -> decltype(o.publish_synchronized(coordination).ref_count()) { in in()
220 return o.publish_synchronized(coordination).ref_count(); in in()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-timer.hpp | 56 , coordination(std::move(cn)) in timer_initial_type()
60 coordination_type coordination; member
71 initial.when = initial.coordination.now() + p; in timer()
78 auto coordinator = initial.coordination.create_coordinator(o.get_subscription()); in on_subscribe()
|
| D | rx-error.hpp | 51 , coordination(std::move(cn)) in error_initial_type()
55 coordination_type coordination; member
68 auto coordinator = initial.coordination.create_coordinator(o.get_subscription()); in on_subscribe()
|
| D | rx-interval.hpp | 57 , coordination(std::move(cn)) in interval_initial_type()
62 coordination_type coordination; member
75 auto coordinator = initial.coordination.create_coordinator(o.get_subscription()); in on_subscribe()
|
| D | rx-range.hpp | 51 , coordination(std::move(cn)) in range_state_type()
57 coordination_type coordination; member
69 auto coordinator = initial.coordination.create_coordinator(o.get_subscription()); in on_subscribe()
|
| D | rx-iterate.hpp | 76 , coordination(std::move(cn)) in iterate_initial_type()
80 coordination_type coordination; member
117 auto coordinator = initial.coordination.create_coordinator(o.get_subscription()); in on_subscribe()
|
| /external/Reactive-Extensions/RxCpp/ |
| D | DeveloperManual.md | 5 …or ```scheduler``` and ```worker```. RxCpp adds ```schedulable```, ```coordination``` and ```coord…
13 The new concepts are ```coordination``` and ```coordinator```. I added these to simplify operator i…
15 ```coordination``` is a factory for ```coordinator```s and has a scheduler.
19 …or deal in time (even ```subscribe_on``` and ```observe_on```) take a coordination parameter, not …
21 Here are some supplied functions that will produce a coordination using a particular scheduler.
|