publisher.h

Go to the documentation of this file.

 
#pragma once
 
#include <functional>
 
#include <flyby/message/message.h>
#include <flyby/message/observable.h>
 
namespace flyby {
    class PublishObservable : public Observable {
    public:
        [[nodiscard]] virtual std::shared_ptr<PublishObservable> on_success(const std::function<void()>& fn) = 0;

        [[nodiscard]] virtual std::shared_ptr<PublishObservable> on_failure(const std::function<void()>& fn) = 0;
    };

    class Publisher {
    public:
        static std::shared_ptr<Publisher> create(const std::string& client_id);
 
        virtual ~Publisher() = default;

        virtual bool is_connected() = 0;

        virtual void publish(
            const std::string& topic,
            const std::string& message,
            const std::string& source = std::string()
        ) = 0;

        virtual void publish(const std::string& topic, Message& message) = 0;

        [[nodiscard]] virtual std::shared_ptr<PublishObservable> publish_observe(
            const std::string& topic,
            const std::string& message
        ) = 0;
    };
}  // namespace flyby