mirror of
https://github.com/Naios/continuable.git
synced 2025-12-06 16:56:44 +08:00
121 lines
4.7 KiB
C++
121 lines
4.7 KiB
C++
|
|
/*
|
|
|
|
/~` _ _ _|_. _ _ |_ | _
|
|
\_,(_)| | | || ||_|(_||_)|(/_
|
|
|
|
https://github.com/Naios/continuable
|
|
v4.1.0
|
|
|
|
Copyright(c) 2015 - 2020 Denis Blank <denis.blank at outlook dot com>
|
|
|
|
Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
of this software and associated documentation files(the "Software"), to deal
|
|
in the Software without restriction, including without limitation the rights
|
|
to use, copy, modify, merge, publish, distribute, sublicense, and / or sell
|
|
copies of the Software, and to permit persons to whom the Software is
|
|
furnished to do so, subject to the following conditions :
|
|
|
|
The above copyright notice and this permission notice shall be included in
|
|
all copies or substantial portions of the Software.
|
|
|
|
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
SOFTWARE.
|
|
**/
|
|
|
|
#ifndef CONTINUABLE_PROMISIFY_HPP_INCLUDED
|
|
#define CONTINUABLE_PROMISIFY_HPP_INCLUDED
|
|
|
|
#include <type_traits>
|
|
#include <utility>
|
|
#include <continuable/detail/other/promisify.hpp>
|
|
|
|
namespace cti {
|
|
/// \defgroup Promisify Promisify
|
|
/// provides helper methods to convert various callback styles to
|
|
/// \link continuable_base continuable_bases\endlink.
|
|
/// \{
|
|
|
|
/// Helper class for converting callback taking callable types into a
|
|
/// a continuable. Various styles are supported.
|
|
/// - `from`: Converts callback taking callable types into continuables
|
|
/// which pass an error code as first parameter and the rest of
|
|
/// the result afterwards.
|
|
///
|
|
/// \tparam Result The result of the converted continuable, this should align
|
|
/// with the arguments that are passed to the callback.
|
|
///
|
|
/// \since 3.0.0
|
|
template <typename... Result>
|
|
class promisify {
|
|
using helper = detail::convert::promisify_helper<Result...>;
|
|
|
|
public:
|
|
/// Converts callback taking callable types into a continuable.
|
|
/// This applies to calls which pass an error code as first parameter
|
|
/// and the rest of the asynchronous result afterwards.
|
|
///
|
|
/// See an example of how to promisify boost asio's async_resolve below:
|
|
/// ```cpp
|
|
/// auto async_resolve(std::string host, std::string service) {
|
|
/// return cti::promisify<asio::ip::udp::resolver::iterator>::from(
|
|
/// [&](auto&&... args) {
|
|
/// resolver_.async_resolve(std::forward<decltype(args)>(args)...);
|
|
/// },
|
|
/// std::move(host), std::move(service));
|
|
/// }
|
|
/// ```
|
|
///
|
|
/// A given error variable is converted to the used error type.
|
|
/// If this isn't possible you need to create a custom resolver callable
|
|
/// object \see with for details.
|
|
///
|
|
/// \since 3.0.0
|
|
template <typename Callable, typename... Args>
|
|
static auto from(Callable&& callable, Args&&... args) {
|
|
return helper::template from(detail::convert::default_resolver(),
|
|
std::forward<Callable>(callable),
|
|
std::forward<Args>(args)...);
|
|
}
|
|
|
|
/// \copybrief from
|
|
///
|
|
/// This modification of \ref from additionally takes a resolver callable
|
|
/// object which is used to resolve the promise from the given result.
|
|
///
|
|
/// See an example of how to promisify boost asio's async_resolve below:
|
|
/// ```cpp
|
|
/// auto async_resolve(std::string host, std::string service) {
|
|
/// return cti::promisify<asio::ip::udp::resolver::iterator>::with(
|
|
/// [](auto&& promise, auto&& e, auto&&... args) {
|
|
/// if (e) {
|
|
/// promise.set_exception(std::forward<decltype(e)>(e));
|
|
/// } else {
|
|
/// promise.set_value(std::forward<decltype(args)>(args)...);
|
|
/// }
|
|
/// },
|
|
/// [&](auto&&... args) {
|
|
/// resolver_.async_resolve(std::forward<decltype(args)>(args)...);
|
|
/// },
|
|
/// std::move(host), std::move(service));
|
|
/// }
|
|
/// ```
|
|
///
|
|
/// \since 4.0.0
|
|
template <typename Resolver, typename Callable, typename... Args>
|
|
static auto with(Resolver&& resolver, Callable&& callable, Args&&... args) {
|
|
return helper::template from(std::forward<Resolver>(resolver),
|
|
std::forward<Callable>(callable),
|
|
std::forward<Args>(args)...);
|
|
}
|
|
};
|
|
/// \}
|
|
} // namespace cti
|
|
|
|
#endif // CONTINUABLE_PROMISIFY_HPP_INCLUDED
|