| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-scheduler.hpp | 127 class schedulable;
149 inline void operator()(const schedulable& s, const recurse& r) const;
175 virtual void schedule(const schedulable& scbl) const = 0;
176 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const = 0;
186 static auto check(int) -> decltype((*(CF*)nullptr)(*(schedulable*)nullptr));
258 inline void schedule(const schedulable& scbl) const { in schedule()
264 inline void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
273 inline void schedule(clock_type::duration when, const schedulable& scbl) const { in schedule()
280 …cally(clock_type::time_point initial, clock_type::duration period, const schedulable& scbl) const { in schedule_periodically()
287 …dically(clock_type::duration initial, clock_type::duration period, const schedulable& scbl) const { in schedule_periodically()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | replay.cpp | 34 [&ys, &xs](const rxsc::schedulable&){ in __anon0ead19a20102() argument
39 [&ys, &res](const rxsc::schedulable&){ in __anon0ead19a20202() argument
44 [&res](const rxsc::schedulable&){ in __anon0ead19a20302() argument
52 [connection, &ys](const rxsc::schedulable&){ in __anon0ead19a20402() argument
56 [connection](const rxsc::schedulable&){ in __anon0ead19a20502() argument
65 [connection, &ys](const rxsc::schedulable&){ in __anon0ead19a20602() argument
69 [connection](const rxsc::schedulable&){ in __anon0ead19a20702() argument
78 [connection, &ys](const rxsc::schedulable&){ in __anon0ead19a20802() argument
82 [connection](const rxsc::schedulable&){ in __anon0ead19a20902() argument
147 [&ys, &xs](const rxsc::schedulable&){ in __anon0ead19a20a02() argument
[all …]
|
| D | publish.cpp | 171 [&ys, &xs](const rxsc::schedulable&){ in __anon1940ffec1202() argument
177 [&ys, &res](const rxsc::schedulable&){ in __anon1940ffec1302() argument
182 [&res](const rxsc::schedulable&){ in __anon1940ffec1402() argument
190 [connection, &ys](const rxsc::schedulable&){ in __anon1940ffec1502() argument
194 [connection](const rxsc::schedulable&){ in __anon1940ffec1602() argument
203 [connection, &ys](const rxsc::schedulable&){ in __anon1940ffec1702() argument
207 [connection](const rxsc::schedulable&){ in __anon1940ffec1802() argument
216 [connection, &ys](const rxsc::schedulable&){ in __anon1940ffec1902() argument
220 [connection](const rxsc::schedulable&){ in __anon1940ffec1a02() argument
286 [&ys, &xs](const rxsc::schedulable&){ in __anon1940ffec1b02() argument
[all …]
|
| D | filter.cpp | 320 [&invoked, &res, &ys, &xs](const rxsc::schedulable&) { in __anon6fc0999b0a02() argument
330 w.schedule_absolute(rxsc::test::subscribed_time, [&ys, &res](const rxsc::schedulable&) { in __anon6fc0999b0c02() argument
334 w.schedule_absolute(rxsc::test::unsubscribed_time, [&res](const rxsc::schedulable&) { in __anon6fc0999b0d02() argument
|
| /external/Reactive-Extensions/RxCpp/ |
| D | DeveloperManual.md | 5 …ave an explanation for ```scheduler``` and ```worker```. RxCpp adds ```schedulable```, ```coordina…
9 …schedulable```s for the timeline and has a lifetime. When the time for an ```schedulable``` is rea…
11 …schedulable``` owns a function and has a ```worker``` and a ```lifetime```. When the ```schedulabl…
17 … ```worker```, and is a factory for coordinated observables, subscribers and schedulable functions.
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/ |
| D | subject.cpp | 490 w.schedule_absolute(100, [&s, &o, &checks, &record](const rxsc::schedulable&){ in __anon9dc5bb691c02() argument
492 w.schedule_absolute(200, [&xs, &o, &record](const rxsc::schedulable&){ in __anon9dc5bb691d02() argument
494 w.schedule_absolute(1000, [&o, &record](const rxsc::schedulable&){ in __anon9dc5bb691e02() argument
497 w.schedule_absolute(300, [&s, &results1, &record](const rxsc::schedulable&){ in __anon9dc5bb691f02() argument
499 w.schedule_absolute(400, [&s, &results2, &record](const rxsc::schedulable&){ in __anon9dc5bb692002() argument
501 w.schedule_absolute(900, [&s, &results3, &record](const rxsc::schedulable&){ in __anon9dc5bb692102() argument
504 w.schedule_absolute(600, [&results1, &record](const rxsc::schedulable&){ in __anon9dc5bb692202() argument
506 w.schedule_absolute(700, [&results2, &record](const rxsc::schedulable&){ in __anon9dc5bb692302() argument
508 w.schedule_absolute(800, [&results1, &record](const rxsc::schedulable&){ in __anon9dc5bb692402() argument
510 w.schedule_absolute(950, [&results3, &record](const rxsc::schedulable&){ in __anon9dc5bb692502() argument
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | replay.cpp | 41 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon0d788ac00602() argument
48 …le(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::schedulable&){ in __anon0d788ac00902() argument
55 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon0d788ac00c02() argument
98 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon0d788ac01202() argument
105 …le(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::schedulable&){ in __anon0d788ac01502() argument
112 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon0d788ac01802() argument
155 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon0d788ac01e02() argument
162 …le(coordination.now() + std::chrono::milliseconds(175), [&](const rxcpp::schedulers::schedulable&){ in __anon0d788ac02102() argument
169 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon0d788ac02402() argument
212 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon0d788ac02a02() argument
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-buffer_time_count.hpp | 112 auto disposer = [=](const rxsc::schedulable&){ in buffer_with_time_or_count_observer() argument
137 …lState->worker.schedule(produce_time, [new_id, produce_time, localState](const rxsc::schedulable&){ in buffer_with_time_or_count_observer() argument
142 …static std::function<void(const rxsc::schedulable&)> produce_buffer(int id, rxsc::scheduler::clock… in produce_buffer()
143 auto produce = [id, expected, state](const rxsc::schedulable&) { in produce_buffer() argument
151 … state->worker.schedule(produce_time, [new_id, produce_time, state](const rxsc::schedulable&){ in produce_buffer() argument
160 return std::function<void(const rxsc::schedulable&)>(); in produce_buffer()
163 return std::function<void(const rxsc::schedulable&)>(selectedProduce.get()); in produce_buffer()
168 auto work = [v, localState](const rxsc::schedulable& self){ in on_next()
184 auto work = [e, localState](const rxsc::schedulable&){ in on_error() argument
197 auto work = [localState](const rxsc::schedulable&){ in on_completed() argument
|
| D | rx-window_time_count.hpp | 114 auto disposer = [=](const rxsc::schedulable&){ in window_with_time_or_count_observer() argument
139 …lState->worker.schedule(produce_time, [new_id, produce_time, localState](const rxsc::schedulable&){ in window_with_time_or_count_observer() argument
144 …static std::function<void(const rxsc::schedulable&)> release_window(int id, rxsc::scheduler::clock… in release_window()
145 auto release = [id, expected, state](const rxsc::schedulable&) { in release_window() argument
155 … state->worker.schedule(produce_time, [new_id, produce_time, state](const rxsc::schedulable&){ in release_window() argument
163 return std::function<void(const rxsc::schedulable&)>(); in release_window()
166 return std::function<void(const rxsc::schedulable&)>(selectedRelease.get()); in release_window()
171 auto work = [v, localState](const rxsc::schedulable& self){ in on_next()
188 auto work = [e, localState](const rxsc::schedulable&){ in on_error() argument
203 auto work = [localState](const rxsc::schedulable&){ in on_completed() argument
|
| D | rx-timeout.hpp | 111 auto disposer = [=](const rxsc::schedulable&){ in timeout_observer() argument
130 auto work = [v, localState](const rxsc::schedulable&) { in timeout_observer() argument
145 …static std::function<void(const rxsc::schedulable&)> produce_timeout(std::size_t id, state_type st… in produce_timeout()
146 auto produce = [id, state](const rxsc::schedulable&) { in produce_timeout() argument
157 return std::function<void(const rxsc::schedulable&)>(); in produce_timeout()
160 return std::function<void(const rxsc::schedulable&)>(selectedProduce.get()); in produce_timeout()
165 auto work = [v, localState](const rxsc::schedulable&) { in on_next() argument
183 auto work = [e, localState](const rxsc::schedulable&) { in on_error() argument
197 auto work = [localState](const rxsc::schedulable&) { in on_completed() argument
|
| D | rx-debounce.hpp | 104 auto disposer = [=](const rxsc::schedulable&){ in debounce_observer() argument
124 …static std::function<void(const rxsc::schedulable&)> produce_item(std::size_t id, state_type state… in produce_item()
125 auto produce = [id, state](const rxsc::schedulable&) { in produce_item() argument
137 return std::function<void(const rxsc::schedulable&)>(); in produce_item()
140 return std::function<void(const rxsc::schedulable&)>(selectedProduce.get()); in produce_item()
145 auto work = [v, localState](const rxsc::schedulable&) { in on_next() argument
163 auto work = [e, localState](const rxsc::schedulable&) { in on_error() argument
178 auto work = [localState](const rxsc::schedulable&) { in on_completed() argument
|
| D | rx-window_time.hpp | 119 auto disposer = [=](const rxsc::schedulable&){ in window_with_time_observer() argument
144 auto release_window = [localState](const rxsc::schedulable&) { in window_with_time_observer() argument
145 localState->worker.schedule([localState](const rxsc::schedulable&) { in window_with_time_observer() argument
157 auto create_window = [localState, selectedRelease](const rxsc::schedulable&) { in window_with_time_observer() argument
163 … localState->worker.schedule(produce_at, [localState, selectedRelease](const rxsc::schedulable&) { in window_with_time_observer() argument
177 [localState, selectedCreate](const rxsc::schedulable&) { in window_with_time_observer() argument
184 auto work = [v, localState](const rxsc::schedulable&){ in on_next() argument
200 auto work = [e, localState](const rxsc::schedulable&){ in on_error() argument
217 auto work = [localState](const rxsc::schedulable&){ in on_completed() argument
|
| D | rx-buffer_time.hpp | 127 auto disposer = [=](const rxsc::schedulable&){ in buffer_with_time_observer() argument
152 auto produce_buffer = [localState](const rxsc::schedulable&) { in buffer_with_time_observer() argument
163 auto create_buffer = [localState, selectedProduce](const rxsc::schedulable&) { in buffer_with_time_observer() argument
167 … localState->worker.schedule(produce_at, [localState, selectedProduce](const rxsc::schedulable&) { in buffer_with_time_observer() argument
181 [localState, selectedCreate](const rxsc::schedulable&) { in buffer_with_time_observer() argument
187 auto work = [v, localState](const rxsc::schedulable&){ in on_next() argument
202 auto work = [e, localState](const rxsc::schedulable&){ in on_error() argument
215 auto work = [localState](const rxsc::schedulable&){ in on_completed() argument
|
| D | rx-sample_time.hpp | 99 auto disposer = [=](const rxsc::schedulable&){ in sample_with_time_observer() argument
118 auto produce_sample = [localState](const rxsc::schedulable&) { in sample_with_time_observer() argument
134 [localState, selectedProduce](const rxsc::schedulable&) { in sample_with_time_observer() argument
141 auto work = [v, localState](const rxsc::schedulable&) { in on_next() argument
155 auto work = [e, localState](const rxsc::schedulable&) { in on_error() argument
169 auto work = [localState](const rxsc::schedulable&) { in on_completed() argument
|
| D | rx-delay.hpp | 100 auto disposer = [=](const rxsc::schedulable&){ in delay_observer() argument
122 auto work = [v, localState](const rxsc::schedulable&){ in on_next() argument
136 auto work = [e, localState](const rxsc::schedulable&){ in on_error() argument
150 auto work = [localState](const rxsc::schedulable&){ in on_completed() argument
|
| D | rx-subscribe_on.hpp | 106 auto disposer = [=](const rxsc::schedulable&){ in on_subscribe() argument
128 auto producer = [=](const rxsc::schedulable&){ in on_subscribe() argument
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/ |
| D | interval.cpp | 14 [=, &c](rxsc::schedulable scbl){ in __anone7f0b85f0102()
37 rxsc::schedulable activity){ in __anone7f0b85f0202()
40 [period, activity](rxsc::schedulable self) { in __anone7f0b85f0202()
57 rxsc::make_schedulable(w, [=, &c](rxsc::schedulable scbl){ in __anone7f0b85f0402()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-virtualtime.hpp | 60 virtual void schedule_absolute(absolute, const schedulable&) const =0;
62 virtual void schedule_relative(relative when, const schedulable& a) const { in schedule_relative()
206 virtual void schedule_absolute(typename base::absolute when, const schedulable& a) const in schedule_absolute()
212 [a](const schedulable& scbl) { in schedule_absolute()
|
| D | rx-test.hpp | 33 virtual void schedule_absolute(long when, const schedulable& a) const in schedule_absolute()
77 virtual void schedule(const schedulable& scbl) const { in schedule()
81 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
85 void schedule_absolute(absolute when, const schedulable& scbl) const { in schedule_absolute()
89 void schedule_relative(relative when, const schedulable& scbl) const { in schedule_relative()
252 [n, o](const schedulable&) { in on_subscribe() argument
305 [this, n](const schedulable&) { in hot_observable() argument
424 void schedule_absolute(long when, const schedulable& a) const { in schedule_absolute()
428 void schedule_relative(long when, const schedulable& a) const { in schedule_relative()
485 schedule_absolute(created, [createSource, state](const schedulable&) { in start() argument
[all …]
|
| D | rx-currentthread.hpp | 156 virtual void schedule(const schedulable& scbl) const { in schedule()
160 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
182 virtual void schedule(const schedulable& scbl) const { in schedule()
186 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
|
| D | rx-immediate.hpp | 37 virtual void schedule(const schedulable& scbl) const { in schedule()
45 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
|
| D | rx-eventloop.hpp | 54 virtual void schedule(const schedulable& scbl) const { in schedule()
58 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
|
| D | rx-newthread.hpp | 133 virtual void schedule(const schedulable& scbl) const { in schedule()
137 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
|
| D | rx-runloop.hpp | 73 virtual void schedule(const schedulable& scbl) const { in schedule()
77 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | subscription.cpp | 40 auto loop = [&](const rxsc::schedulable& self) { in __anoncf43e2d30302()
85 auto loop = [&](const rxsc::schedulable& self) { in __anoncf43e2d30702()
127 auto loop = [&](const rxsc::schedulable& self) { in __anoncf43e2d30a02()
236 auto loop = [&](const rxsc::schedulable& self) { in __anoncf43e2d31602()
|