diff --git a/src/rpp/rpp/observers/lambda_observer.hpp b/src/rpp/rpp/observers/lambda_observer.hpp index 0a9c25e4b..2cbdc4af4 100644 --- a/src/rpp/rpp/observers/lambda_observer.hpp +++ b/src/rpp/rpp/observers/lambda_observer.hpp @@ -22,6 +22,14 @@ template OnCompleted> struct lambda_strategy { + template TOnNext, rpp::constraint::decayed_same_as TOnError, rpp::constraint::decayed_same_as TOnCompleted> + explicit lambda_strategy(TOnNext&& on_next, TOnError&& on_error, TOnCompleted&& on_completed) + : on_next{std::forward(on_next)} + , on_error{std::forward(on_error)} + , on_completed{std::forward(on_completed)} + { + } + RPP_NO_UNIQUE_ADDRESS OnNext on_next{}; RPP_NO_UNIQUE_ADDRESS OnError on_error{}; RPP_NO_UNIQUE_ADDRESS OnCompleted on_completed{};