promise.h

Go to the documentation of this file.

 
#pragma once
 
#include <future>
#include <utility>
#include <promeki/core/namespace.h>
#include <promeki/core/future.h>
 
PROMEKI_NAMESPACE_BEGIN
 
template <typename T>
class Promise {
        public:
                Promise() = default;
 
                ~Promise() = default;
 
                Promise(const Promise &) = delete;
                Promise &operator=(const Promise &) = delete;
 
                Promise(Promise &&other) = default;
 
                Promise &operator=(Promise &&other) = default;
 
                void setValue(T value) {
                        _promise.set_value(std::move(value));
                }
 
                void setError(Error error) {
                        _promise.set_exception(
                                std::make_exception_ptr(PromiseError(error)));
                }
 
                Future<T> future() {
                        return Future<T>(_promise.get_future());
                }
 
        private:
                struct PromiseError {
                        Error error;
                        PromiseError(Error e) : error(e) {}
                };
 
                std::promise<T> _promise;
};
 
template <>
class Promise<void> {
        public:
                Promise() = default;
 
                ~Promise() = default;
 
                Promise(const Promise &) = delete;
                Promise &operator=(const Promise &) = delete;
                Promise(Promise &&other) = default;
                Promise &operator=(Promise &&other) = default;
 
                void setValue() {
                        _promise.set_value();
                }
 
                void setError(Error error) {
                        _promise.set_exception(
                                std::make_exception_ptr(PromiseError(error)));
                }
 
                Future<void> future() {
                        return Future<void>(_promise.get_future());
                }
 
        private:
                struct PromiseError {
                        Error error;
                        PromiseError(Error e) : error(e) {}
                };
 
                std::promise<void> _promise;
};
 
PROMEKI_NAMESPACE_END