ReactivePlusPlus
ReactiveX implementation for C++20
|
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... | |
Observable is the observable and observer at the same time. Uses as a bridge and for manual sending of values.