ReactivePlusPlus
ReactiveX implementation for C++20
|
Public Member Functions | |
template<rpp::constraint::decayed_same_as< OnNext > TOnNext, rpp::constraint::decayed_same_as< OnError > TOnError, rpp::constraint::decayed_same_as< OnCompleted > TOnCompleted> | |
lambda_strategy (TOnNext &&on_next, TOnError &&on_error, TOnCompleted &&on_completed) | |
Static Public Member Functions | |
static void | set_upstream (const disposable_wrapper &) noexcept |
static bool | is_disposed () noexcept |
Public Attributes | |
RPP_NO_UNIQUE_ADDRESS OnNext | on_next {} |
RPP_NO_UNIQUE_ADDRESS OnError | on_error {} |
RPP_NO_UNIQUE_ADDRESS OnCompleted | on_completed {} |
Static Public Attributes | |
static constexpr auto | preferred_disposables_mode = rpp::details::observers::disposables_mode::Auto |