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() |