RemoteObjectCallbackTemplate.h

Go to the documentation of this file.

// (c) IMT - Information Management Technology AG, CH-9470 Buchs, www.imt.ch.
 
#ifndef IMT_BASE_LIB_REMOTING_REMOTEOBJECTCALLBACKTEMPLATE_H
#define IMT_BASE_LIB_REMOTING_REMOTEOBJECTCALLBACKTEMPLATE_H
 
#include <functional>
#include <Imt.Base.Core.Platform/Platform.h>
#include <Imt.Base.Lib.Remoting/RemoteObjectAbs.h>
 
namespace imt {
namespace base {
namespace lib {
namespace remoting {
 
template<class ProtocolType, uint16_t PROTOCOL_ID>
class RemoteObjectCallbackTemplate final : public RemoteObjectAbs {
 
public:
 
    RemoteObjectCallbackTemplate(RemotingSendServiceIfc* const pRemotingSendService, std::function<ProtocolType const&()> sendCallback) :
        RemoteObjectCallbackTemplate {pRemotingSendService, sendCallback, nullptr, {}} {
    }
 
    RemoteObjectCallbackTemplate(RemotingServiceIfc* const pRemotingReceiveService, std::function<void(ProtocolType const&)> receiveCallback) :
        RemoteObjectCallbackTemplate {nullptr, {}, pRemotingReceiveService, receiveCallback} {
    }
 
    RemoteObjectCallbackTemplate(RemotingSendServiceIfc* const pRemotingSendService, std::function<ProtocolType const&()> sendCallback,
        RemotingServiceIfc* const pRemotingReceiveService, std::function<void(ProtocolType const&)> receiveCallback) :
        RemoteObjectAbs {static_cast<int32_t>(PROTOCOL_ID), pRemotingSendService, pRemotingReceiveService},
        m_sendCallback {std::move(sendCallback)},
        m_receiveCallback {std::move(receiveCallback)} {
    }
 
    void deserialize(::imt::base::core::serialization::Deserializer& buffer) final {
        ProtocolType const message {buffer};
        if (m_receiveCallback) {
            m_receiveCallback(message);
        }
    }
 
    void serialize(::imt::base::core::serialization::Serializer& buffer) const final {
        if (m_sendCallback) {
            ProtocolType const& messageToSend {m_sendCallback()};
            messageToSend.serialize(buffer);
        }
    }
 
private:
 
    std::function<ProtocolType const&()> m_sendCallback;
    std::function<void(ProtocolType const&)> m_receiveCallback;
};
 
} // namespace remoting
} // namespace lib
} // namespace base
} // namespace imt
 
#endif // IMT_BASE_LIB_REMOTING_REMOTEOBJECTCALLBACKTEMPLATE_H