Home
last modified time | relevance | path

Searched refs:scbl (Results 1 – 10 of 10) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-scheduler.hpp175 virtual void schedule(const schedulable& scbl) const = 0;
176 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const = 0;
258 inline void schedule(const schedulable& scbl) const { in schedule()
260 schedule_rebind(scbl); in schedule()
264 inline void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
266 schedule_rebind(when, scbl); in schedule()
273 inline void schedule(clock_type::duration when, const schedulable& scbl) const { in schedule()
275 schedule_rebind(now() + when, scbl); in schedule()
280 …cally(clock_type::time_point initial, clock_type::duration period, const schedulable& scbl) const { in schedule_periodically()
282 schedule_periodically_rebind(initial, period, scbl); in schedule_periodically()
[all …]
Drx-coordination.hpp201 auto operator()(const rxsc::schedulable& scbl) const in operator ()()
202 -> decltype(dest(scbl)) { in operator ()()
204 return dest(scbl); in operator ()()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-currentthread.hpp156 virtual void schedule(const schedulable& scbl) const { in schedule()
157 queue_type::push(queue_type::item_type(now(), scbl)); in schedule()
160 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
161 queue_type::push(queue_type::item_type(when, scbl)); in schedule()
182 virtual void schedule(const schedulable& scbl) const { in schedule()
183 schedule(now(), scbl); in schedule()
186 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
187 if (!scbl.is_subscribed()) { in schedule()
195 queue_type::get_worker_interface()->schedule(when, scbl); in schedule()
209 if (scbl.is_subscribed()) { in schedule()
[all …]
Drx-immediate.hpp37 virtual void schedule(const schedulable& scbl) const { in schedule()
38 if (scbl.is_subscribed()) { in schedule()
41 scbl(r.get_recurse()); in schedule()
45 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
47 if (scbl.is_subscribed()) { in schedule()
50 scbl(r.get_recurse()); in schedule()
Drx-eventloop.hpp54 virtual void schedule(const schedulable& scbl) const { in schedule()
55 controller.schedule(lifetime, scbl.get_action()); in schedule()
58 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
59 controller.schedule(when, lifetime, scbl.get_action()); in schedule()
Drx-newthread.hpp133 virtual void schedule(const schedulable& scbl) const { in schedule()
134 schedule(now(), scbl); in schedule()
137 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
138 if (scbl.is_subscribed()) { in schedule()
140 state->q.push(new_worker_state::item_type(when, scbl)); in schedule()
Drx-runloop.hpp73 virtual void schedule(const schedulable& scbl) const { in schedule()
74 schedule(now(), scbl); in schedule()
77 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
78 if (scbl.is_subscribed()) { in schedule()
83 st->q.push(detail::run_loop_state::item_type(when, scbl)); in schedule()
Drx-virtualtime.hpp212 [a](const schedulable& scbl) { in schedule_absolute() argument
215 if (scbl.is_subscribed()) { in schedule_absolute()
216 scbl.unsubscribe(); // unsubscribe() run, not a; in schedule_absolute()
Drx-test.hpp77 virtual void schedule(const schedulable& scbl) const { in schedule()
78 state->schedule_absolute(state->clock(), scbl); in schedule()
81 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
82 state->schedule_relative(state->to_relative(when - now()), scbl); in schedule()
85 void schedule_absolute(absolute when, const schedulable& scbl) const { in schedule_absolute()
86 state->schedule_absolute(when, scbl); in schedule_absolute()
89 void schedule_relative(relative when, const schedulable& scbl) const { in schedule_relative()
90 state->schedule_relative(when, scbl); in schedule_relative()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/
Dinterval.cpp14 [=, &c](rxsc::schedulable scbl){ in __anon75bcabbb0102() argument
15 auto nsDelta = duration_cast<milliseconds>(scbl.now() - (start + (period * c))); in __anon75bcabbb0102()
18 if (c == 5) {scbl.unsubscribe();} in __anon75bcabbb0102()
57 rxsc::make_schedulable(w, [=, &c](rxsc::schedulable scbl){ in __anon75bcabbb0402() argument
58 auto nsDelta = duration_cast<milliseconds>(scbl.now() - (start + (period * c))); in __anon75bcabbb0402()
61 if (c == 5) {scbl.unsubscribe();} in __anon75bcabbb0402()