ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::schedulers::new_thread::worker_strategy Class Reference

Public Types

using new_thread_schedulable = schedulable_wrapper< worker_strategy >
 

Public Member Functions

 worker_strategy (const rpp::composite_subscription &sub)
 
bool is_subscribed () const
 
void defer_at (time_point time_point, constraint::schedulable_fn auto &&fn) const
 
void defer_at (time_point time_point, new_thread_schedulable &&fn) const
 

Static Public Member Functions

static time_point now ()
 

The documentation for this class was generated from the following file: