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. | |
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) && |
Extension over rpp::observable to provide ability statically keep one of multiple observables.