|
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) |