Observables

Observable is the source of any Reactive Stream. Observable provides ability to subscribe observer on some events. More...

Classes
class	rpp::blocking_observable< Type, OriginalObservable >
	blocking alternative of observable: provides interface where each function do blocking subscribe on original observable (waits till on_completed and provides value) More...
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 More...
class	rpp::dynamic_observable< Type >
	Type-less observable (or partially untyped) that has the notion of Type but hides the notion of on_subscribe<Type> for C++ compiler. More...
class	rpp::specific_observable< Type, OnSubscribeFn >
	Type-full observable (or typed) that has the notion of Type and upstream observables for C++ compiler. e.g. observable<int, map<bool, ...recursive...>> is different from observable<int, filter<int, ...>>. More...

Detailed Description

Observable is the source of any Reactive Stream. Observable provides ability to subscribe observer on some events.

See also

https://reactivex.io/documentation/observable.html