sink.hpp

#ifndef SIPLASPLAS_SIGNALS_SINK_HPP
#define SIPLASPLAS_SIGNALS_SINK_HPP

#include <siplasplas/typeerasure/simpleany.hpp>
#include <siplasplas/signals/export.hpp>
#include <type_traits>

namespace cpp
{

class SignalEmitter;

class SIPLASPLAS_SIGNALS_EXPORT SignalSink
{
public:

    template<typename Caller, typename Callee>
    SignalSink(Caller& caller, Callee& callee) :
        _caller{&caller},
        _callee{&callee}
    {}

    template<typename Caller>
    SignalSink(Caller& caller) :
        _caller{&caller},
        _callee{}
    {}

    virtual ~SignalSink() = default;

    template<typename... Args>
    void operator()(Args&&... args)
    {
        if(invokeWithoutCallee())
        {
            invoke(
                std::vector<cpp::SimpleAny32>{
                    std::forward<Args>(args)...
                }
            );
        }
        else
        {
            invoke(
                std::vector<cpp::SimpleAny32>{
                    _callee, std::forward<Args>(args)...
                }
            );
        }
    }

    SignalEmitter* callee() const
    {
        return _callee.get<SignalEmitter*>();
    }

    SignalEmitter* caller() const
    {
        return _caller.get<SignalEmitter*>();
    }

    virtual bool pull() = 0;

protected:
    virtual void invoke(std::vector<cpp::SimpleAny32>&& args) = 0;
    virtual bool invokeWithoutCallee() const = 0;

private:
    cpp::SimpleAny32 _caller, _callee;
};

}

#endif // SIPLASPLAS_SIGNALS_SINK_HPP