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()
301     void schedule_rebind(const schedulable& scbl, ArgN&&... an) const;
312     void schedule_rebind(clock_type::time_point when, const schedulable& scbl, ArgN&&... an) const;
323 …ind(clock_type::time_point initial, clock_type::duration period, const schedulable& scbl, ArgN&&..…
426 class schedulable : public schedulable_base  class
428     typedef schedulable this_type;
507     ~schedulable()  in ~schedulable()
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
564     inline static schedulable empty(worker sc) {  in empty()
565         return schedulable(composite_subscription::empty(), sc, action::empty());  in empty()
660     typedef std::function<void(const schedulable&, const recurse&)> function_type;
675     inline void operator()(const schedulable& s, const recurse& r) {  in operator ()()
689     typedef std::function<void(const schedulable&)> function_type;
704     inline void operator()(const schedulable& s, const recurse& r) {  in operator ()()
726 inline void action::operator()(const schedulable& s, const recurse& r) const {  in operator ()()
743     const   schedulable& scbl)  in make_schedulable()
744     ->      schedulable {  in make_schedulable()
745     return  schedulable(scbl);  in make_schedulable()
749             schedulable&& scbl)  in make_schedulable()
750     ->      schedulable {  in make_schedulable()
751     return  schedulable(std::move(scbl));  in make_schedulable()
754 inline schedulable make_schedulable(worker sc, action a) {  in make_schedulable()
755     return schedulable(sc, a);  in make_schedulable()
757 inline schedulable make_schedulable(worker sc, composite_subscription cs, action a) {  in make_schedulable()
758     return schedulable(cs, sc, a);  in make_schedulable()
763     -> typename std::enable_if<detail::is_action_function<F>::value, schedulable>::type {  in make_schedulable()
764     return schedulable(sc, make_action(std::forward<F>(f)));  in make_schedulable()
768     -> typename std::enable_if<detail::is_action_function<F>::value, schedulable>::type {  in make_schedulable()
769     return schedulable(cs, sc, make_action(std::forward<F>(f)));  in make_schedulable()
772 auto make_schedulable(schedulable scbl, composite_subscription cs, F&& f)  in make_schedulable()
773     -> typename std::enable_if<detail::is_action_function<F>::value, schedulable>::type {  in make_schedulable()
774     return schedulable(cs, scbl.get_worker(), make_action(std::forward<F>(f)));  in make_schedulable()
777 auto make_schedulable(schedulable scbl, worker sc, F&& f)  in make_schedulable()
778     -> typename std::enable_if<detail::is_action_function<F>::value, schedulable>::type {  in make_schedulable()
779     return schedulable(scbl, sc, make_action(std::forward<F>(f)));  in make_schedulable()
782 auto make_schedulable(schedulable scbl, F&& f)  in make_schedulable()
783     -> typename std::enable_if<detail::is_action_function<F>::value, schedulable>::type {  in make_schedulable()
784     return schedulable(scbl, scbl.get_worker(), make_action(std::forward<F>(f)));  in make_schedulable()
787 inline auto make_schedulable(schedulable scbl, composite_subscription cs)  in make_schedulable()
788     -> schedulable {  in make_schedulable()
789     return schedulable(cs, scbl.get_worker(), scbl.get_action());  in make_schedulable()
791 inline auto make_schedulable(schedulable scbl, worker sc, composite_subscription cs)  in make_schedulable()
792     -> schedulable {  in make_schedulable()
793     return schedulable(cs, sc, scbl.get_action());  in make_schedulable()
795 inline auto make_schedulable(schedulable scbl, worker sc)  in make_schedulable()
796     -> schedulable {  in make_schedulable()
797     return schedulable(scbl, sc, scbl.get_action());  in make_schedulable()
812 void worker::schedule_rebind(const schedulable& scbl, ArgN&&... an) const {  in schedule_rebind()
831 void worker::schedule_rebind(clock_type::time_point when, const schedulable& scbl, ArgN&&... an) co…  in schedule_rebind()
847 …ind(clock_type::time_point initial, clock_type::duration period, const schedulable& scbl, ArgN&&..…  in schedule_periodically_rebind()
853         [keepAlive, target, period, activity](schedulable self) {  in schedule_periodically_rebind()
875     time_schedulable(TimePoint when, schedulable a)  in time_schedulable()
881     schedulable what;