client.h

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

#pragma once

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

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

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

    ZEROEQ_API explicit Client(const URIs& uris);

    ZEROEQ_API explicit Client(Receiver& shared);

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

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

    ZEROEQ_API ~Client();

    ZEROEQ_API bool request(const servus::Serializable& request,
                            const ReplyFunc& func);

    ZEROEQ_API bool request(const uint128_t& request, const void* data,
                            size_t size, const ReplyFunc& func);

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