invoker.hpp

Go to the documentation of this file.

#ifndef LIBFILEZILLA_INVOKER_HEADER
#define LIBFILEZILLA_INVOKER_HEADER

#include "event_handler.hpp"

namespace fz {

struct invoker_event_type{};

typedef simple_event<invoker_event_type, std::function<void()>> invoker_event;

class FZ_PUBLIC_SYMBOL thread_invoker final : public event_handler
{
public:
    thread_invoker(event_loop& loop);
    virtual ~thread_invoker();

    virtual void operator()(event_base const& ev) override;
};

template<typename F>
auto make_invoker(event_loop& loop, F && f)
{
    return [handler = thread_invoker(loop), cf = std::forward<F>(f)](auto &&... args) mutable -> decltype(f(std::forward<decltype(args)>(args)...), void())
    {
        auto cb = [cf = std::move(cf), targs = std::make_tuple(std::forward<decltype(args)>(args)...)] {
            std::apply(cf, targs);
        };
        handler.send_event<invoker_event>(std::move(cb));
    };
}

template<typename F>
auto make_invoker(event_handler& h, F && f)
{
    return make_invoker(h.event_loop_, std::forward<F>(f));
}


typedef std::function<void(std::function<void()>)> invoker_factory;

invoker_factory FZ_PUBLIC_SYMBOL get_invoker_factory(event_loop& loop);

template<typename F>
auto make_invoker(invoker_factory const& inv, F && f)
{
    return [inv, cf = std::forward<F>(f)](auto &&... args) mutable -> decltype(f(std::forward<decltype(args)>(args)...), void())
    {
        auto cb = [cf = std::move(cf), targs = std::make_tuple(std::forward<decltype(args)>(args)...)] {
            std::apply(cf, targs);
        };
        inv(cb);
    };
}

}

#endif