ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::details::timeout_state< FallbackObs > Struct Template Reference
Inheritance diagram for rpp::details::timeout_state< FallbackObs >:
rpp::details::early_unsubscribe_state rpp::details::timeout_state_with_serialized_spinlock< FallbackObs >

Public Member Functions

 timeout_state (const FallbackObs &fallback_obs, const composite_subscription &subscription_of_subscriber)
 
- Public Member Functions inherited from rpp::details::early_unsubscribe_state
 early_unsubscribe_state (const composite_subscription &subscription_of_subscriber)
 

Public Attributes

FallbackObs fallback_obs
 
std::atomic< schedulers::time_point > last_emission_time {}
 
- Public Attributes inherited from rpp::details::early_unsubscribe_state
composite_subscription children_subscriptions
 

Static Public Attributes

static constexpr schedulers::time_point s_timeout_reached = schedulers::time_point::min()
 

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