reply.hpp

//SPDX-License-Identifier: LicenseRef-Apache-License-2.0
//Author: Blayne Dennis
 
#ifndef __SIMPLE_THREADING_REPLY__
#define __SIMPLE_THREADING_REPLY__
 
#include <memory>
#include <deque>
 
#include "utility.hpp"
#include "context.hpp"
#include "channel.hpp"
 
namespace st { // simple thread
namespace detail {
namespace reply {
 
struct context {
    context(st::channel ch, std::size_t id) :
        m_ch(std::move(ch)),
        m_id(id)
    { }
 
    virtual ~context(){ }
 
    template <typename T>
    bool send(T&& t) {
        return m_ch.send(m_id, std::forward<T>(t));
    }
 
    st::channel m_ch;
    std::size_t m_id;
};
 
}
}
 
struct reply : public st::shared_context<reply, detail::reply::context> {
    virtual ~reply(){}
    
    template <typename CHANNEL>
    static reply make(CHANNEL&& ch, std::size_t id = 0) { 
        reply r;
        r.ctx(std::make_shared<detail::reply::context>(std::forward<CHANNEL>(ch), id));
        return r;
    }
 
    template <typename T>
    bool send(T&& t) {
        return ctx() ? ctx()->send(std::forward<T>(t)) : false;
    }
};
 
}
 
#endif