receiver.h

/* Copyright (c) 2014-2017, Human Brain Project
 *                          Stefan.Eilemann@epfl.ch
 */

#ifndef ZEROEQ_RECEIVER_H
#define ZEROEQ_RECEIVER_H

#include <zeroeq/api.h>
#include <zeroeq/types.h>

#include <memory>

#include <string>
#include <vector>

namespace zeroeq
{
namespace connection
{
namespace detail
{
class Broker;
}
}

class Receiver
{
public:
    ZEROEQ_API Receiver();

    ZEROEQ_API explicit Receiver(Receiver& shared);

    ZEROEQ_API virtual ~Receiver();
    ZEROEQ_API Receiver(Receiver&&);
    ZEROEQ_API Receiver& operator=(Receiver&&);

    ZEROEQ_API bool receive(const uint32_t timeout = TIMEOUT_INDEFINITE);

protected:
    virtual void addSockets(std::vector<detail::Socket>& entries) = 0;

    virtual bool process(detail::Socket& socket) = 0;

    virtual void update() {}

    ZEROEQ_API virtual void addConnection(const std::string& uri);
    friend class connection::detail::Broker;

private:
    Receiver& operator=(const Receiver&) = delete;

    class Impl;
    std::shared_ptr<Impl> _impl;
};
}

#endif