receiver.h

/* Copyright (c) 2014-2015, 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 detail
{
class Receiver;
}
namespace connection
{
namespace detail
{
class Broker;
}
}

class Receiver
{
public:
    ZEROEQ_API Receiver();

    ZEROEQ_API explicit Receiver(Receiver& shared);

    ZEROEQ_API virtual ~Receiver();

    ZEROEQ_API bool receive(const uint32_t timeout = TIMEOUT_INDEFINITE);

protected:
    friend class detail::Receiver;

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

    virtual void process(detail::Socket& socket, uint32_t timeout) = 0;

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

    void* getZMQContext(); 

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

    std::shared_ptr<detail::Receiver> const _impl;
};
}

#endif