The state that caches the values from all the observables and dispatches latest caches to the observer. Note the emission is only sent to the observer when all the observables at least emits once. More...

#include <combine_latest.hpp>

Inheritance diagram for rpp::details::combine_latest_state< TCombiner, Types >:

Public Member Functions
	combine_latest_state (const TCombiner &combiner, const composite_subscription &subscription_of_subscriber)

Public Member Functions inherited from rpp::details::merge_state
	early_unsubscribe_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
TCombiner	combiner

std::mutex	values_mutex {}

std::tuple< std::optional< Types >... >	values {}

Public Attributes inherited from rpp::details::merge_state
std::atomic_size_t	count_of_on_completed_needed {}

Public Attributes inherited from rpp::details::early_unsubscribe_state
composite_subscription	children_subscriptions

Detailed Description

template<typename TCombiner, constraint::decayed_type... Types>
struct rpp::details::combine_latest_state< TCombiner, Types >

The state that caches the values from all the observables and dispatches latest caches to the observer. Note the emission is only sent to the observer when all the observables at least emits once.

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

src/rpp/rpp/operators/combine_latest.hpp

Public Member Functions

Public Attributes

Detailed Description