|
Clio
develop
The XRP Ledger API server.
|
Base class for single feed. More...
#include <SingleFeedBase.hpp>

Public Member Functions | |
| SingleFeedBase (util::async::AnyExecutionContext &executionCtx, std::string const &name) | |
| Construct a new Single Feed Base object. | |
| void | sub (SubscriberSharedPtr const &subscriber) |
| Subscribe the feed. | |
| void | unsub (SubscriberSharedPtr const &subscriber) |
| Unsubscribe the feed. | |
| void | pub (std::string msg) |
| Publishes the feed in strand. | |
| std::uint64_t | count () const |
| Get the count of subscribers. | |
Base class for single feed.
| feed::impl::SingleFeedBase::SingleFeedBase | ( | util::async::AnyExecutionContext & | executionCtx, |
| std::string const & | name ) |
Construct a new Single Feed Base object.
| executionCtx | The actual publish will be called in the strand of this. |
| name | The prometheus counter name of the feed. |
| void feed::impl::SingleFeedBase::pub | ( | std::string | msg | ) |
Publishes the feed in strand.
| msg | The message. |
| void feed::impl::SingleFeedBase::sub | ( | SubscriberSharedPtr const & | subscriber | ) |
Subscribe the feed.
| subscriber |
| void feed::impl::SingleFeedBase::unsub | ( | SubscriberSharedPtr const & | subscriber | ) |
Unsubscribe the feed.
| subscriber |