ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::dynamic_observable< Type > Class Template Reference

Type-erased version of the rpp::observable. Any observable can be converted to dynamic_observable via rpp::observable::as_dynamic member function. More...

#include <dynamic_observable.hpp>

Inheritance diagram for rpp::dynamic_observable< Type >:
rpp::observable< Type, details::observables::dynamic_strategy< Type > >

Public Member Functions

 dynamic_observable (base &&b)
 
 dynamic_observable (const base &b)
 
- Public Member Functions inherited from rpp::observable< Type, details::observables::dynamic_strategy< Type > >
 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| (Op &&op) const &
 
auto operator| (Op &&op) &&
 
auto operator| (Op &&op) const &
 
auto operator| (Op &&op) &&
 
auto operator| (const rpp::operators::details::subscribe_t< Args... > &op) const
 
auto operator| (rpp::operators::details::subscribe_t< Args... > &&op) const
 
auto pipe (Op &&op) const &
 
auto pipe (Op &&op) &&
 

Additional Inherited Members

- Public Types inherited from rpp::observable< Type, details::observables::dynamic_strategy< Type > >
using value_type
 
using strategy_type
 
using expected_disposable_strategy
 

Detailed Description

template<constraint::decayed_type Type>
class rpp::dynamic_observable< Type >

Type-erased version of the rpp::observable. Any observable can be converted to dynamic_observable via rpp::observable::as_dynamic member function.

To provide type-erasure it uses std::shared_ptr. As a result it has worse performance.

Template Parameters
Typeof value this obsevalbe can provide

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