|
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 |