Home
last modified time | relevance | path

Searched defs:schedulable (Results 1 – 21 of 21) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dreplay.cpp34 [&ys, &xs](const rxsc::schedulable&){ in __anon9c790cfe0102()
39 [&ys, &res](const rxsc::schedulable&){ in __anon9c790cfe0202()
44 [&res](const rxsc::schedulable&){ in __anon9c790cfe0302()
52 [connection, &ys](const rxsc::schedulable&){ in __anon9c790cfe0402()
56 [connection](const rxsc::schedulable&){ in __anon9c790cfe0502()
65 [connection, &ys](const rxsc::schedulable&){ in __anon9c790cfe0602()
69 [connection](const rxsc::schedulable&){ in __anon9c790cfe0702()
78 [connection, &ys](const rxsc::schedulable&){ in __anon9c790cfe0802()
82 [connection](const rxsc::schedulable&){ in __anon9c790cfe0902()
147 [&ys, &xs](const rxsc::schedulable&){ in __anon9c790cfe0a02()
[all …]
Dpublish.cpp171 [&ys, &xs](const rxsc::schedulable&){ in __anon608b5ec81202()
177 [&ys, &res](const rxsc::schedulable&){ in __anon608b5ec81302()
182 [&res](const rxsc::schedulable&){ in __anon608b5ec81402()
190 [connection, &ys](const rxsc::schedulable&){ in __anon608b5ec81502()
194 [connection](const rxsc::schedulable&){ in __anon608b5ec81602()
203 [connection, &ys](const rxsc::schedulable&){ in __anon608b5ec81702()
207 [connection](const rxsc::schedulable&){ in __anon608b5ec81802()
216 [connection, &ys](const rxsc::schedulable&){ in __anon608b5ec81902()
220 [connection](const rxsc::schedulable&){ in __anon608b5ec81a02()
286 [&ys, &xs](const rxsc::schedulable&){ in __anon608b5ec81b02()
[all …]
Dfilter.cpp320 [&invoked, &res, &ys, &xs](const rxsc::schedulable&) { in __anonfd8c8cf70a02()
330 w.schedule_absolute(rxsc::test::subscribed_time, [&ys, &res](const rxsc::schedulable&) { in __anonfd8c8cf70c02()
334 w.schedule_absolute(rxsc::test::unsubscribed_time, [&res](const rxsc::schedulable&) { in __anonfd8c8cf70d02()
Dwindow.cpp97 [&](const rxsc::schedulable&) { in __anon62ce1ea90202()
105 [&](const rxsc::schedulable&) { in __anon62ce1ea90302()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/
Dsubject.cpp490 w.schedule_absolute(100, [&s, &o, &checks, &record](const rxsc::schedulable&){ in __anon2b91aec51c02()
492 w.schedule_absolute(200, [&xs, &o, &record](const rxsc::schedulable&){ in __anon2b91aec51d02()
494 w.schedule_absolute(1000, [&o, &record](const rxsc::schedulable&){ in __anon2b91aec51e02()
497 w.schedule_absolute(300, [&s, &results1, &record](const rxsc::schedulable&){ in __anon2b91aec51f02()
499 w.schedule_absolute(400, [&s, &results2, &record](const rxsc::schedulable&){ in __anon2b91aec52002()
501 w.schedule_absolute(900, [&s, &results3, &record](const rxsc::schedulable&){ in __anon2b91aec52102()
504 w.schedule_absolute(600, [&results1, &record](const rxsc::schedulable&){ in __anon2b91aec52202()
506 w.schedule_absolute(700, [&results2, &record](const rxsc::schedulable&){ in __anon2b91aec52302()
508 w.schedule_absolute(800, [&results1, &record](const rxsc::schedulable&){ in __anon2b91aec52402()
510 w.schedule_absolute(950, [&results3, &record](const rxsc::schedulable&){ in __anon2b91aec52502()
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
Dreplay.cpp41 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c0602()
48 …le(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c0902()
55 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c0c02()
98 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c1202()
105 …le(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c1502()
112 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c1802()
155 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c1e02()
162 …le(coordination.now() + std::chrono::milliseconds(175), [&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c2102()
169 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c2402()
212 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c2a02()
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-window_time.hpp119 auto disposer = [=](const rxsc::schedulable&){ in window_with_time_observer()
144 auto release_window = [localState](const rxsc::schedulable&) { in window_with_time_observer()
145 localState->worker.schedule([localState](const rxsc::schedulable&) { in window_with_time_observer()
157 auto create_window = [localState, selectedRelease](const rxsc::schedulable&) { in window_with_time_observer()
163 … localState->worker.schedule(produce_at, [localState, selectedRelease](const rxsc::schedulable&) { in window_with_time_observer()
177 [localState, selectedCreate](const rxsc::schedulable&) { in window_with_time_observer()
184 auto work = [v, localState](const rxsc::schedulable&){ in on_next()
200 auto work = [e, localState](const rxsc::schedulable&){ in on_error()
217 auto work = [localState](const rxsc::schedulable&){ in on_completed()
Drx-buffer_time.hpp127 auto disposer = [=](const rxsc::schedulable&){ in buffer_with_time_observer()
152 auto produce_buffer = [localState](const rxsc::schedulable&) { in buffer_with_time_observer()
163 auto create_buffer = [localState, selectedProduce](const rxsc::schedulable&) { in buffer_with_time_observer()
167 … localState->worker.schedule(produce_at, [localState, selectedProduce](const rxsc::schedulable&) { in buffer_with_time_observer()
181 [localState, selectedCreate](const rxsc::schedulable&) { in buffer_with_time_observer()
187 auto work = [v, localState](const rxsc::schedulable&){ in on_next()
202 auto work = [e, localState](const rxsc::schedulable&){ in on_error()
215 auto work = [localState](const rxsc::schedulable&){ in on_completed()
Drx-sample_time.hpp99 auto disposer = [=](const rxsc::schedulable&){ in sample_with_time_observer()
118 auto produce_sample = [localState](const rxsc::schedulable&) { in sample_with_time_observer()
134 [localState, selectedProduce](const rxsc::schedulable&) { in sample_with_time_observer()
141 auto work = [v, localState](const rxsc::schedulable&) { in on_next()
155 auto work = [e, localState](const rxsc::schedulable&) { in on_error()
169 auto work = [localState](const rxsc::schedulable&) { in on_completed()
Drx-buffer_time_count.hpp112 auto disposer = [=](const rxsc::schedulable&){ in buffer_with_time_or_count_observer()
137 …lState->worker.schedule(produce_time, [new_id, produce_time, localState](const rxsc::schedulable&){ in buffer_with_time_or_count_observer()
143 auto produce = [id, expected, state](const rxsc::schedulable&) { in produce_buffer()
151 … state->worker.schedule(produce_time, [new_id, produce_time, state](const rxsc::schedulable&){ in produce_buffer()
184 auto work = [e, localState](const rxsc::schedulable&){ in on_error()
197 auto work = [localState](const rxsc::schedulable&){ in on_completed()
Drx-timeout.hpp111 auto disposer = [=](const rxsc::schedulable&){ in timeout_observer()
130 auto work = [v, localState](const rxsc::schedulable&) { in timeout_observer()
146 auto produce = [id, state](const rxsc::schedulable&) { in produce_timeout()
165 auto work = [v, localState](const rxsc::schedulable&) { in on_next()
183 auto work = [e, localState](const rxsc::schedulable&) { in on_error()
197 auto work = [localState](const rxsc::schedulable&) { in on_completed()
Drx-window_time_count.hpp114 auto disposer = [=](const rxsc::schedulable&){ in window_with_time_or_count_observer()
139 …lState->worker.schedule(produce_time, [new_id, produce_time, localState](const rxsc::schedulable&){ in window_with_time_or_count_observer()
145 auto release = [id, expected, state](const rxsc::schedulable&) { in release_window()
155 … state->worker.schedule(produce_time, [new_id, produce_time, state](const rxsc::schedulable&){ in release_window()
188 auto work = [e, localState](const rxsc::schedulable&){ in on_error()
203 auto work = [localState](const rxsc::schedulable&){ in on_completed()
Drx-debounce.hpp104 auto disposer = [=](const rxsc::schedulable&){ in debounce_observer()
125 auto produce = [id, state](const rxsc::schedulable&) { in produce_item()
145 auto work = [v, localState](const rxsc::schedulable&) { in on_next()
163 auto work = [e, localState](const rxsc::schedulable&) { in on_error()
178 auto work = [localState](const rxsc::schedulable&) { in on_completed()
Drx-delay.hpp100 auto disposer = [=](const rxsc::schedulable&){ in delay_observer()
122 auto work = [v, localState](const rxsc::schedulable&){ in on_next()
136 auto work = [e, localState](const rxsc::schedulable&){ in on_error()
150 auto work = [localState](const rxsc::schedulable&){ in on_completed()
Drx-subscribe_on.hpp106 auto disposer = [=](const rxsc::schedulable&){ in on_subscribe()
128 auto producer = [=](const rxsc::schedulable&){ in on_subscribe()
Drx-window_toggle.hpp207 auto work = [v, localState](const rxsc::schedulable&){ in on_next()
223 auto work = [e, localState](const rxsc::schedulable&){ in on_error()
240 auto work = [localState](const rxsc::schedulable&){ in on_completed()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-test.hpp252 [n, o](const schedulable&) { in on_subscribe()
305 [this, n](const schedulable&) { in hot_observable()
485 schedule_absolute(created, [createSource, state](const schedulable&) { in start()
488 schedule_absolute(subscribed, [state](const schedulable&) { in start()
491 schedule_absolute(unsubscribed, [state](const schedulable&) { in start()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/
Drx-timer.hpp81 auto producer = [o](const rxsc::schedulable&) { in on_subscribe()
Drx-interval.hpp81 auto producer = [o, counter](const rxsc::schedulable&) { in on_subscribe()
Drx-error.hpp72 auto producer = [=](const rxsc::schedulable&){ in on_subscribe()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-scheduler.hpp426 class schedulable : public schedulable_base class
513 schedulable() in schedulable() function in rxcpp::schedulers::schedulable
519 schedulable(worker q, action a) in schedulable() function in rxcpp::schedulers::schedulable
527 schedulable(composite_subscription cs, worker q, action a) in schedulable() function in rxcpp::schedulers::schedulable
536 schedulable(schedulable scbl, worker q, action a) in schedulable() function in rxcpp::schedulers::schedulable