ReactivePlusPlus
ReactiveX implementation for C++20
|
Classes | |
struct | state_t |
Public Types | |
using | Observable = rpp::utils::extract_observer_type_t<TObserver> |
using | value_type = rpp::utils::extract_observable_type_t<Observable> |
using | Subject = forwarding_subject<value_type> |
Public Member Functions | |
window_toggle_state (TObserver &&observer, const TClosingsSelectorFn &closings) | |
rpp::utils::pointer_under_lock< state_t > | get_state_under_lock () |
template<typename T > | |
auto | get_closing (T &&v) const |
auto | on_new_subject (const Subject &subject) |