"combine_latest" operator (an OperatorFn used by "lift"). More...
#include <combine_latest.hpp>
Public Types | |
using | DownstreamType = utils::decayed_invoke_result_t< TCombiner, Type, utils::extract_observable_type_t< TOtherObservable >... > |
Public Member Functions | |
template<constraint::subscriber_of_type< DownstreamType > TSub> | |
auto | operator() (TSub &&in_subscriber) const |
Public Attributes | |
RPP_NO_UNIQUE_ADDRESS TCombiner | m_combiner |
RPP_NO_UNIQUE_ADDRESS std::tuple< TOtherObservable... > | m_other_observables |
"combine_latest" operator (an OperatorFn used by "lift").