ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
template<typename T> | |
void | on_next (T &&v) const |
![]() | |
void | set_upstream (const rpp::disposable_wrapper &d) const |
bool | is_disposed () const |
void | on_error (const std::exception_ptr &err) const |
void | on_completed () const |
Additional Inherited Members | |
![]() | |
std::shared_ptr< zip_disposable< Observer, TSelector, Args... > > | disposable |
![]() | |
static constexpr auto | preferred_disposables_mode |