IPubsub.h

Go to the documentation of this file.

#ifndef ZSERIO_IPUBSUB_H_INC
#define ZSERIO_IPUBSUB_H_INC
 
#include <memory>
#include <string_view>
 
#include "zserio/Span.h"
#include "zserio/Types.h"
 
namespace zserio
{
 
class IPubsub
{
public:
    virtual ~IPubsub() = default;
 
    using SubscriptionId = size_t;
 
    class OnTopicCallback
    {
    public:
        virtual ~OnTopicCallback() = default;
        virtual void operator()(std::string_view topic, Span<const uint8_t> data) = 0;
    };
 
    virtual void publish(std::string_view topic, Span<const uint8_t> data, void* context) = 0;
 
    virtual SubscriptionId subscribe(
            std::string_view topic, const std::shared_ptr<OnTopicCallback>& callback, void* context) = 0;
 
    virtual void unsubscribe(SubscriptionId id) = 0;
};
 
} // namespace zserio
 
#endif // ZSERIO_IPUBSUB_H_INC