syncsink.hpp

#ifndef SIPLASPLAS_SIGNALS_SYNCSINK_HPP
#define SIPLASPLAS_SIGNALS_SYNCSINK_HPP

#include "sink.hpp"
#include <siplasplas/typeerasure/function.hpp>
#include <siplasplas/signals/export.hpp>

namespace cpp
{

class SIPLASPLAS_SIGNALS_EXPORT SyncSink : public SignalSink
{
public:
    template<typename Caller, typename Function>
    SyncSink(Caller& caller, Function function) :
        SignalSink{caller},
        _fptr{function}
    {}

    template<typename Caller, typename Callee, typename Function>
    SyncSink(Caller& caller, Callee& callee, Function function) :
        SignalSink{caller, callee},
        _fptr{function}
    {}

    bool pull() override;

    virtual ~SyncSink() = default;

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

private:
    cpp::typeerasure::Function32 _fptr;
};

}

#endif // SIPLASPLAS_SIGNALS_SYNCSINK_HPP