| ReactivePlusPlus
    ReactiveX implementation for C++20 | 
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. | |
| 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. | |
| 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_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. | |
| 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. | |
| 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) && | 
Extension over rpp::observable to provide ability statically keep one of multiple observables.