request.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_DATATASK_REQUEST_HPP
#define RTCTK_DATATASK_REQUEST_HPP
 
#include <future>
 
namespace rtctk::dataTask {
 
// TODO: reply code by std::error_code
template <typename REQ_TYPE>
class [[deprecated]] Request {
public:
    explicit Request(const REQ_TYPE& req_payload)
        : m_req_payload(req_payload), m_rep_promise(std::make_shared<std::promise<void>>()) {
    }
 
    Request(const Request& r) = default;
 
    Request& operator=(const Request& r) = default;
 
    const REQ_TYPE& GetPayload() const {
        return m_req_payload;
    }
 
    std::future<void> GetReplyFuture() const {
        return m_rep_promise->get_future();
    }
 
    void SetReply() const {
        m_rep_promise->set_value();
    }
 
    // template <class T>
    // void SetException(const T& e) const {
    //     m_rep_promise->set_exception(boost::copy_exception(e));
    // }
 
private:
    REQ_TYPE m_req_payload;  // Payload associated to the request.
    std::shared_ptr<std::promise<void>>
        m_rep_promise;  // Pointer to the promise associated to the reply.
};
 
}  // namespace rtctk::dataTask
 
#endif  // RTCTK_DATATASK_REQUEST_HPP