counting_completion.hpp

// SPDX-License-Identifier: LGPL-2.1-or-later
 
#pragma once
 
#include <vitrio/concurrency/completion.hpp>
#include <vitrio/concurrency/completion_notifier.hpp>
#include <vitrio/export.hpp>
 
#include <cstddef>
#include <memory>
 
namespace vitrio
{
 
class counting_completion final
    : public completion
    , public completion_notifier
{
public:
    VITRIO_API
    explicit counting_completion(std::size_t count);
 
    counting_completion(const counting_completion &other) = delete;
    counting_completion(counting_completion &&other) = delete;
 
    VITRIO_API
    ~counting_completion() override;
 
    counting_completion&
    operator=(const counting_completion &other) = delete;
    counting_completion&
    operator=(counting_completion &&other) = delete;
 
    VITRIO_API
    void notify_done(std::exception_ptr error = nullptr) override;
 
    VITRIO_API
    void wait() const override;
 
    VITRIO_API
    bool is_ready() const noexcept override;
 
    VITRIO_API
    void get() const override;
 
private:
    class implementation;
    std::unique_ptr<implementation> m_implementation;
};
 
} // namespace vitrio