// Copyright 2021 gRPC authors. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. #ifndef GRPC_CORE_LIB_PROMISE_MAP_H #define GRPC_CORE_LIB_PROMISE_MAP_H #include #include #include #include #include "absl/types/variant.h" #include "src/core/lib/promise/detail/promise_like.h" #include "src/core/lib/promise/poll.h" namespace grpc_core { namespace promise_detail { // Implementation of mapping combinator - use this via the free function below! // Promise is the type of promise to poll on, Fn is a function that takes the // result of Promise and maps it to some new type. template class Map { public: Map(Promise promise, Fn fn) : promise_(std::move(promise)), fn_(std::move(fn)) {} using PromiseResult = typename PromiseLike::Result; using Result = RemoveCVRef()(std::declval()))>; Poll operator()() { Poll r = promise_(); if (auto* p = absl::get_if(&r)) { return fn_(std::move(*p)); } return Pending(); } private: PromiseLike promise_; Fn fn_; }; } // namespace promise_detail // Mapping combinator. // Takes a promise, and a synchronous function to mutate its result, and // returns a promise. template promise_detail::Map Map(Promise promise, Fn fn) { return promise_detail::Map(std::move(promise), std::move(fn)); } // Callable that takes a tuple and returns one element template struct JustElem { template auto operator()(std::tuple&& t) const -> decltype(std::get(std::forward>(t))) { return std::get(std::forward>(t)); } template auto operator()(const std::tuple& t) const -> decltype(std::get(t)) { return std::get(t); } }; } // namespace grpc_core #endif // GRPC_CORE_LIB_PROMISE_MAP_H