ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Types | |
using | base = connectable_observable<rpp::dynamic_observable<rpp::subjects::utils::extract_subject_type_t<Subject>>, Subject> |
Public Member Functions | |
template<rpp::constraint::observable_strategy< rpp::subjects::utils::extract_subject_type_t< Subject > > Strategy> requires (!rpp::constraint::decayed_same_as<Strategy, rpp::dynamic_observable<rpp::subjects::utils::extract_subject_type_t<Subject>>>) | |
dynamic_connectable_observable (const rpp::connectable_observable< Strategy, Subject > &original) | |
template<rpp::constraint::observable_strategy< rpp::subjects::utils::extract_subject_type_t< Subject > > Strategy> requires (!rpp::constraint::decayed_same_as<Strategy, rpp::dynamic_observable<rpp::subjects::utils::extract_subject_type_t<Subject>>>) | |
dynamic_connectable_observable (rpp::connectable_observable< Strategy, Subject > &&original) | |
Public Member Functions inherited from rpp::connectable_observable< rpp::dynamic_observable< rpp::subjects::utils::extract_subject_type_t< Subject > >, Subject > | |
connectable_observable (const OriginalObservable &original_observable, const Subject &subject) | |
connectable_observable (OriginalObservable &&original_observable, const Subject &subject) | |
rpp::disposable_wrapper | connect (rpp::composite_disposable_wrapper wrapper=composite_disposable_wrapper::make()) const |
Connects to underlying observable right-now making it hot-observable. | |
auto | ref_count () const |
Forces rpp::connectable_observable to behave like common observable. | |
auto | operator| (Op &&op) const & |
auto | operator| (Op &&op) && |
auto | pipe (Op &&op) const & |
auto | pipe (Op &&op) && |
auto | as_dynamic_connectable () const & |
auto | as_dynamic_connectable () && |
connectable_observable (const OriginalObservable &original_observable, const Subject &subject) | |
connectable_observable (OriginalObservable &&original_observable, const Subject &subject) | |
rpp::disposable_wrapper | connect (rpp::composite_disposable_wrapper wrapper=composite_disposable_wrapper::make()) const |
Connects to underlying observable right-now making it hot-observable. | |
auto | ref_count () const |
Forces rpp::connectable_observable to behave like common observable. | |
auto | operator| (Op &&op) const & |
auto | operator| (Op &&op) && |
auto | pipe (Op &&op) const & |
auto | pipe (Op &&op) && |
auto | as_dynamic_connectable () const & |
auto | as_dynamic_connectable () && |