connectable alternative of observable: extends interface with extra functionality. Common subscription will subscribe on underlying subject, but connect/ref_count will initiate subscription on original observable More...

#include <connectable_observable.hpp>

Inheritance diagram for rpp::connectable_observable< Type, Subject, OriginalObservable >:

Public Member Functions
	connectable_observable (const OriginalObservable &original_observable, const Subject &subject=Subject{})

	connectable_observable (OriginalObservable &&original_observable, const Subject &subject=Subject{})

composite_subscription	connect (const composite_subscription &subscription=composite_subscription{}) const

Detailed Description

template<constraint::decayed_type Type, subjects::constraint::subject_of_type< Type > Subject, constraint::observable_of_type< Type > OriginalObservable>
class rpp::connectable_observable< Type, Subject, OriginalObservable >

connectable alternative of observable: extends interface with extra functionality. Common subscription will subscribe on underlying subject, but connect/ref_count will initiate subscription on original observable

Template Parameters

Type	type of values emitted by this observable
OriginalObservable	original observable wrapped by this observable

See also: https://reactivex.io/documentation/operators/publish.html

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

src/rpp/rpp/observables/connectable_observable.hpp

Public Member Functions

Detailed Description