ReactivePlusPlus
ReactiveX implementation for C++20
Loading...
Searching...
No Matches
Subjects

Observable is the observable and observer at the same time. Uses as a bridge and for manual sending of values. More...

Classes

class  rpp::subjects::behavior_subject< Type >
 Same as rpp::subjects::publish_subject but keeps last value (or default) and emits it to newly subscribed observer. More...
 
class  rpp::subjects::serialized_behavior_subject< Type >
 Same as rpp::subjects::behavior_subject but on_next/on_error/on_completed calls are serialized via mutex. More...
 
class  rpp::subjects::publish_subject< Type >
 Subject which just multicasts values to observers subscribed on it. It contains two parts: observer and observable at the same time. More...
 
class  rpp::subjects::serialized_publish_subject< Type >
 Serialized version of rpp::subjects::publish_subject. More...
 
class  rpp::subjects::replay_subject< Type >
 Same as rpp::subjects::publish_subject but send all earlier emitted values to any new observers. More...
 
class  rpp::subjects::serialized_replay_subject< Type >
 Same as rpp::subjects::replay_subject but on_next/on_error/on_completed calls are serialized via mutex. More...
 

Detailed Description

Observable is the observable and observer at the same time. Uses as a bridge and for manual sending of values.

See also
https://reactivex.io/documentation/subject.html