monitor.h

/* Copyright (c) 2017, Human Brain Project
 *                          Stefan.Eilemann@epfl.ch
 */

#pragma once

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

namespace zeroeq
{
class Monitor : public Receiver
{
public:
    ZEROEQ_API explicit Monitor(Sender& sender);

    ZEROEQ_API Monitor(Sender& sender, Receiver& shared);

    ZEROEQ_API ~Monitor();

    virtual void notifyNewConnection() {}

    class Impl;

private:
    std::unique_ptr<Impl> _impl;

    Monitor(const Monitor&) = delete;
    Monitor& operator=(const Monitor&) = delete;

    // Receiver API
    void addSockets(std::vector<zeroeq::detail::Socket>& entries) final;
    bool process(zeroeq::detail::Socket& socket) final;
};
}