subscriber.h

/* Copyright (c) 2014-2017, 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 <zeroeq/uri.h>      // used inline

#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 URIs& uris);

    ZEROEQ_API explicit Subscriber(Receiver& shared);

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

    ZEROEQ_API Subscriber(const URIs& uris, Receiver& shared);

    ZEROEQ_API ~Subscriber();

    explicit Subscriber(const URI& uri) 
        : Subscriber(URIs{uri})
    {
    }
    Subscriber(const URI& uri, Receiver& shared) 
        : Subscriber(URIs{uri}, shared)
    {
    }

    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;
    bool process(detail::Socket& socket) final;
    void update() final;
    void addConnection(const std::string& uri) final;
};
}

#endif