ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
template<typename T > | |
void | on_next (T &&v) const |
void | on_error (const std::exception_ptr &err) const |
void | set_upstream (const disposable_wrapper &d) |
bool | is_disposed () const |
void | on_completed () const |
Public Attributes | |
std::shared_ptr< concat_state_t< TObserver, PackedContainer > > | state {} |
bool | locally_disposed {} |
Static Public Attributes | |
static constexpr auto | preferred_disposables_mode = rpp::details::observers::disposables_mode::None |