FutureBase.hpp

Go to the documentation of this file.

#pragma once

#include <zeus/FutureData.hpp>

namespace zeus {
    class FutureBase {
        public:
            ememory::SharedPtr<zeus::FutureData> m_data; // Reference on the data
        public:
            FutureBase(const zeus::FutureBase& _base);
            FutureBase();
            FutureBase(uint32_t _transactionId, zeus::FutureData::ObserverFinish _callback=nullptr, uint32_t _clientId=0);
            FutureBase(uint32_t _transactionId, ememory::SharedPtr<zeus::Buffer> _returnData, zeus::FutureData::ObserverFinish _callback=nullptr, uint32_t _clientId=0);
            zeus::FutureBase operator= (const zeus::FutureBase& _base);
            bool appendData(ememory::SharedPtr<zeus::Buffer> _returnValue);
            void setSynchronous();
            uint32_t getTransactionId() const;
            uint32_t getClientId() const;
            bool hasError() const;
            std::string getErrorType() const;
            std::string getErrorHelp() const;
            bool isValid() const;
            bool isFinished() const;
            const FutureBase& wait() const;
            const FutureBase& waitFor(std::chrono::microseconds _delta = std::chrono::seconds(30)) const;
            const FutureBase& waitUntil(std::chrono::steady_clock::time_point _endTime) const;
            ememory::SharedPtr<zeus::Buffer> getRaw();
            std::chrono::nanoseconds getTransmitionTime() const;
    };
}