ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::details::debounce_state_with_serialized_spinlock< T, Scheduler, TSub > Struct Template Reference
Inheritance diagram for rpp::details::debounce_state_with_serialized_spinlock< T, Scheduler, TSub >:
rpp::details::debounce_state< T, Scheduler > rpp::details::early_unsubscribe_state

Public Types

using InnerSub = decltype(make_serialized_subscriber(std::declval< TSub >(), std::declval< std::reference_wrapper< utils::spinlock > >()))
 
- Public Types inherited from rpp::details::debounce_state< T, Scheduler >
using Worker = decltype(std::declval< Scheduler >().create_worker(std::declval< composite_subscription >()))
 

Public Member Functions

 debounce_state_with_serialized_spinlock (auto &&sub, schedulers::duration period, const Scheduler &scheduler)
 
- Public Member Functions inherited from rpp::details::debounce_state< T, Scheduler >
 debounce_state (schedulers::duration period, const Scheduler &scheduler, const composite_subscription &subscription_of_subscriber)
 
std::optional< schedulers::time_point > emplace_safe (auto &&v)
 
std::variant< std::monostate, T, schedulers::duration > extract_value_or_time ()
 
std::optional< T > extract_value ()
 
const Worker & get_worker () const
 
- Public Member Functions inherited from rpp::details::early_unsubscribe_state
 early_unsubscribe_state (const composite_subscription &subscription_of_subscriber)
 

Public Attributes

utils::spinlock spinlock {}
 
InnerSub subscriber
 
- Public Attributes inherited from rpp::details::early_unsubscribe_state
composite_subscription children_subscriptions
 

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