|
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.