subscriber.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 SubscribeObservable : public Observable {
    public:
        [[nodiscard]] virtual std::shared_ptr<SubscribeObservable> on_success(const std::function<void()>& fn) = 0;

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

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

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

        virtual bool is_connected() = 0;

        [[nodiscard]] virtual std::shared_ptr<SubscribeObservable> subscribe(const std::string& topic) = 0;
    };
}  // namespace flyby