SingleFeedBase.hpp

#pragma once
 
#include "feed/Types.hpp"
#include "feed/impl/TrackableSignal.hpp"
#include "util/async/AnyExecutionContext.hpp"
#include "util/async/AnyStrand.hpp"
#include "util/log/Logger.hpp"
#include "util/prometheus/Gauge.hpp"
 
#include <boost/asio/io_context.hpp>
#include <boost/asio/strand.hpp>
 
#include <cstdint>
#include <functional>
#include <memory>
#include <string>
 
namespace feed::impl {

class SingleFeedBase {
    util::async::AnyStrand strand_;
    std::reference_wrapper<util::prometheus::GaugeInt> subCount_;
    TrackableSignal<Subscriber, std::shared_ptr<std::string> const&> signal_;
    util::Logger logger_{"Subscriptions"};
    std::string name_;
 
public:
    SingleFeedBase(util::async::AnyExecutionContext& executionCtx, std::string const& name);

    void
    sub(SubscriberSharedPtr const& subscriber);

    void
    unsub(SubscriberSharedPtr const& subscriber);

    void
    pub(std::string msg);

    std::uint64_t
    count() const;
 
private:
    void
    unsubInternal(SubscriberPtr subscriber);
};
}  // namespace feed::impl