ReactivePlusPlus
ReactiveX implementation for C++20
|
Classes | |
struct | vtable_t |
Public Member Functions | |
void | set_upstream (const disposable_wrapper &d) noexcept |
bool | is_disposed () const noexcept |
void | on_next (const Type &v) const noexcept |
void | on_next (Type &&v) const noexcept |
void | on_error (const std::exception_ptr &err) const noexcept |
void | on_completed () const noexcept |
Protected Member Functions | |
observer_vtable (vtable_t &&vtable) | |
Protected Attributes | |
const vtable_t | m_vtable {} |