subscriber.h

/* Copyright (c) 2014-2016, Human Brain Project
 *                          Daniel Nachbaur <daniel.nachbaur@epfl.ch>
 *                          Stefan.Eilemann@epfl.ch
 */

#ifndef ZEROEQ_SUBSCRIBER_H
#define ZEROEQ_SUBSCRIBER_H

#include <zeroeq/receiver.h> // base class

#include <vector>

namespace zeroeq
{
class Subscriber : public Receiver
{
public:
    ZEROEQ_API Subscriber();

    ZEROEQ_API explicit Subscriber(const std::string& session);

    ZEROEQ_API explicit Subscriber(const URI& uri);

    ZEROEQ_API Subscriber(const URI& uri, const std::string& session);

    ZEROEQ_API explicit Subscriber(Receiver& shared);

    ZEROEQ_API Subscriber(const std::string& session, Receiver& shared);

    ZEROEQ_API Subscriber(const URI& uri, Receiver& shared);

    ZEROEQ_API Subscriber(const URI& uri, const std::string& session,
                          Receiver& shared);

    ZEROEQ_API ~Subscriber();

    ZEROEQ_API bool subscribe(servus::Serializable& serializable);

    ZEROEQ_API bool subscribe(const uint128_t& event, const EventFunc& func);

    ZEROEQ_API bool subscribe(const uint128_t& event,
                              const EventPayloadFunc& func);

    ZEROEQ_API bool unsubscribe(const servus::Serializable& serializable);

    ZEROEQ_API bool unsubscribe(const uint128_t& event);

    ZEROEQ_API const std::string& getSession() const;

private:
    class Impl;
    std::unique_ptr<Impl> _impl;

    // Receiver API
    void addSockets(std::vector<detail::Socket>& entries) final;
    void process(detail::Socket& socket, uint32_t timeout) final;
    void update() final;
    void addConnection(const std::string& uri) final;
};
}

#endif