ReactivePlusPlus
ReactiveX implementation for C++20
Loading...
Searching...
No Matches
rpp::variant_observable< Type, Observables > Class Template Reference

Extension over rpp::observable to provide ability statically keep one of multiple observables. More...

#include <variant_observable.hpp>

Additional Inherited Members

- Public Types inherited from rpp::observable< Type, details::variant_observable_strategy< Type, Observables... > >
using value_type
 
using strategy_type
 
using optimal_disposables_strategy
 
- Public Member Functions inherited from rpp::observable< Type, details::variant_observable_strategy< Type, Observables... > >
 observable (Args &&... args)
 
void subscribe (observer< Type, ObserverStrategy > &&observer) const
 Subscribes passed observer to emissions from this observable.
 
void subscribe (dynamic_observer< Type > observer) const
 Subscribe passed observer to emissions from this observable.
 
void subscribe (ObserverStrategy &&observer_strategy) const
 Subscribes passed observer strategy to emissions from this observable via construction of observer.
 
composite_disposable_wrapper subscribe (const composite_disposable_wrapper &d, observer< Type, ObserverStrategy > &&obs) const
 Subscribe passed observer to emissions from this observable.
 
composite_disposable_wrapper subscribe (const composite_disposable_wrapper &d, ObserverStrategy &&observer_strategy) const
 Subscribes passed observer strategy to emissions from this observable via construction of observer.
 
void subscribe (OnNext &&on_next, OnError &&on_error={}, OnCompleted &&on_completed={}) const
 Construct rpp::lambda_observer on the fly and subscribe it to emissions from this observable.
 
void subscribe (OnNext &&on_next, OnCompleted &&on_completed) const
 Construct rpp::lambda_observer on the fly and subscribe it to emissions from this observable.
 
composite_disposable_wrapper subscribe (const composite_disposable_wrapper &d, OnNext &&on_next, OnError &&on_error={}, OnCompleted &&on_completed={}) const
 Construct rpp::lambda_observer on the fly and subscribe it to emissions from this observable.
 
composite_disposable_wrapper subscribe (const composite_disposable_wrapper &d, OnNext &&on_next, OnCompleted &&on_completed) const
 Construct rpp::lambda_observer on the fly and subscribe it to emissions from this observable.
 
composite_disposable_wrapper subscribe_with_disposable (observer< Type, ObserverStrategy > &&observer) const
 Subscribes passed observer to emissions from this observable.
 
composite_disposable_wrapper subscribe_with_disposable (ObserverStrategy &&observer_strategy) const
 Subscribes observer strategy to emissions from this observable.
 
composite_disposable_wrapper subscribe_with_disposable (dynamic_observer< Type > observer) const
 Subscribe passed observer to emissions from this observable.
 
composite_disposable_wrapper subscribe_with_disposable (OnNext &&on_next, OnError &&on_error={}, OnCompleted &&on_completed={}) const
 Construct rpp::lambda_observer on the fly and subscribe it to emissions from this observable.
 
composite_disposable_wrapper subscribe_with_disposable (OnNext &&on_next, OnCompleted &&on_completed) const
 Construct rpp::lambda_observer on the fly and subscribe it to emissions from this observable.
 
auto as_dynamic () const &
 Convert observable to type-erased version.
 
auto as_dynamic () &&
 Convert observable to type-erased version.
 
auto operator| (Subscribe &&op) const
 
rpp::constraint::observable auto operator| (Op &&op) const &
 
rpp::constraint::observable auto operator| (Op &&op) &&
 
auto pipe (Op &&op) const &
 
auto pipe (Op &&op) &&
 

Detailed Description

template<constraint::decayed_type Type, constraint::observable_of_type< Type >... Observables>
class rpp::variant_observable< Type, Observables >

Extension over rpp::observable to provide ability statically keep one of multiple observables.


The documentation for this class was generated from the following files: