Clio develop
The XRP Ledger API server.
|
Feed that publishes the json object as it is. More...
#include <ForwardFeed.hpp>
Public Member Functions | |
void | pub (boost::json::object const &json) |
Publishes the json object. | |
SingleFeedBase (util::async::AnyExecutionContext &executionCtx, std::string const &name) | |
Construct a new Single Feed Base object. | |
![]() | |
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. | |
Feed that publishes the json object as it is.
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 promethues counter name of the feed. |