ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Types | |
using | optimal_disposables_strategy = typename details::subject_state<Type, Serialized>::optimal_disposables_strategy |
Public Member Functions | |
replay_subject_base (size_t count) | |
replay_subject_base (size_t count, rpp::schedulers::duration duration) | |
auto | get_observer () const |
auto | get_observable () const |
rpp::disposable_wrapper | get_disposable () const |