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 |