request_client.h

Go to the documentation of this file.

#ifndef CPPSERVER_NANOMSG_REQUEST_CLIENT_H
#define CPPSERVER_NANOMSG_REQUEST_CLIENT_H

#include "client.h"

namespace CppServer {
namespace Nanomsg {


class RequestClient : public Client
{
public:

    explicit RequestClient(const std::string& address, bool threading = false)
        : Client(CppServer::Nanomsg::Domain::Std, CppServer::Nanomsg::Protocol::Request, address, threading)
    {}
    RequestClient(const RequestClient&) = delete;
    RequestClient(RequestClient&&) = default;
    virtual ~RequestClient() = default;

    RequestClient& operator=(const RequestClient&) = delete;
    RequestClient& operator=(RequestClient&&) = default;


    Message Request(const void* buffer, size_t size)
    {
        Message message;
        if (Send(buffer, size) == size)
            Receive(message);
        return message;
    }

    Message Request(const std::string& text) { return Request(text.data(), text.size()); }

    Message Request(const Message& message) { return Request(message.buffer(), message.size()); }
};

} // namespace Nanomsg
} // namespace CppServer

#endif // CPPSERVER_NANOMSG_REQUEST_CLIENT_H