observable.hpp

// Copyright Take Vos 2022.
// Distributed under the Boost Software License, Version 1.0.
// (See accompanying file LICENSE_1_0.txt or copy at https://www.boost.org/LICENSE_1_0.txt)
 
#pragma once
 
#include "group_ptr.hpp"
#include "../coroutine/module.hpp"
#include "../macros.hpp"
#include <memory>
#include <vector>
#include <string>
 
namespace hi::inline v1 {
 
struct observable_msg {
    using path_type = std::vector<std::string>;
 
    void const * const ptr;
    path_type const& path;
};
 
class observable : public enable_group_ptr<observable, void(observable_msg)> {
public:
    constexpr virtual ~observable() = default;
    observable(observable const&) = delete;
    observable(observable&&) = delete;
    observable& operator=(observable const&) = delete;
    observable& operator=(observable&&) = delete;
    constexpr observable() noexcept = default;
 
    [[nodiscard]] virtual void const *read() const noexcept = 0;
 
    [[nodiscard]] virtual void *copy(void const *ptr) const noexcept = 0;
 
    virtual void commit(void *ptr) noexcept = 0;
 
    virtual void abort(void *ptr) const noexcept = 0;
 
    virtual void read_lock() const noexcept = 0;
 
    virtual void read_unlock() const noexcept = 0;
 
    virtual void write_lock() const noexcept = 0;
 
    virtual void write_unlock() const noexcept = 0;
};
 
} // namespace hi::inline v1