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 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
 
#endif