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