Public Member Functions | |
concat_state (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 | |
composite_subscription | source_subscription |
std::mutex | queue_mutex {} |
std::queue< dynamic_observable< ValueType > > | observables_to_subscribe {} |
std::atomic_bool | inner_subscribed {} |
Public Attributes inherited from rpp::details::early_unsubscribe_state | |
composite_subscription | children_subscriptions |