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 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