TypedMessage.h

#pragma once
 
#include <pulsar/Message.h>
 
#include <functional>
 
namespace pulsar {
 
template <typename T>
class TypedMessage : public Message {
   public:
    using Decoder = std::function<T(const char*, std::size_t)>;
 
    TypedMessage() = default;
 
    TypedMessage(
        const Message& message, Decoder decoder = [](const char*, std::size_t) { return T{}; })
        : Message(message), decoder_(decoder) {}
 
    T getValue() const { return decoder_(static_cast<const char*>(getData()), getLength()); }
 
    TypedMessage& setDecoder(Decoder decoder) {
        decoder_ = decoder;
        return *this;
    }
 
   private:
    Decoder decoder_;
};
 
}  // namespace pulsar