ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Types | |
using | subject = rpp::subjects::publish_subject<std::tuple<std::decay_t<Args>...>> |
Public Member Functions | |
template<typename... Vals> | |
void | operator() (Vals &&... vals) const |
Public Attributes | |
decltype(std::declval< subject >().get_observer()) | observer |