eventServiceIf.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_EVENTSERVICEIF_HPP
#define RTCTK_COMPONENTFRAMEWORK_EVENTSERVICEIF_HPP
 
#include <rtctk/componentFramework/jsonPayload.hpp>
 
#include <string>
 
namespace rtctk::componentFramework {
 
class EventPublisherIf;
class EventSubscriberIf;

class EventServiceIf {
public:
    virtual ~EventServiceIf() = default;

    virtual std::unique_ptr<EventPublisherIf> MakePublisher(const std::string& topic) = 0;

    virtual std::unique_ptr<EventSubscriberIf> MakeSubscriber(const std::string& topic) = 0;
};

class EventPublisherIf {
public:
    virtual ~EventPublisherIf() = default;

    virtual void Publish(const JsonPayload& sample) = 0;
};

class EventSubscriberIf {
public:
    virtual ~EventSubscriberIf() = default;

    virtual void Subscribe(std::function<void(const JsonPayload&)> cb) = 0;

    virtual void Unsubscribe() = 0;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_EVENTSERVICEIF_HPP