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 <vector>
#include <string>

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() {}

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

    void* getZMQContext(); 

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

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

}

#endif