actor.hpp

Go to the documentation of this file.

/*
 * This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/.
 *
 * This file is part of zmqpp.
 * Copyright (c) 2011-2015 Contributors as noted in the AUTHORS file.
 */

#pragma once

#include <thread>
#include <functional>
#include "socket.hpp"

namespace zmqpp
{

    class actor
    {
    public:
    typedef std::function<bool (socket *pipe) > ActorStartRoutine;

    actor(ActorStartRoutine routine);
    actor(const actor&) = delete;

      actor(actor &&o);

      actor &operator=(actor &&o);

    virtual ~actor();

    socket *pipe();

    const socket *pipe() const;

    bool stop(bool block = false);

    private:
    void start_routine(socket *child, ActorStartRoutine routine);

     std::string bind_parent();

    socket *parent_pipe_;

    socket *child_pipe_;

    static context actor_pipe_ctx_;

    bool stopped_;

    bool retval_;
    };
}