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>

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

Additional Inherited Members
Public Types inherited from rpp::observable< Type, details::observables::dynamic_strategy< Type > >
using	value_type
using	strategy_type
using	optimal_disposables_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

Type	of value this obsevalbe can provide

---

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

• src/rpp/rpp/observables/dynamic_observable.hpp