Base class for single feed.
More...
#include <SingleFeedBase.hpp>
|
| 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.
◆ SingleFeedBase()
Construct a new Single Feed Base object.
- Parameters
-
executionCtx | The actual publish will be called in the strand of this. |
name | The promethues counter name of the feed. |
◆ pub()
void feed::impl::SingleFeedBase::pub |
( |
std::string | msg | ) |
|
Publishes the feed in strand.
- Parameters
-
◆ sub()
void feed::impl::SingleFeedBase::sub |
( |
SubscriberSharedPtr const & | subscriber | ) |
|
Subscribe the feed.
- Parameters
-
◆ unsub()
void feed::impl::SingleFeedBase::unsub |
( |
SubscriberSharedPtr const & | subscriber | ) |
|
Unsubscribe the feed.
- Parameters
-
The documentation for this class was generated from the following files:
- /__w/clio/clio/src/feed/impl/SingleFeedBase.hpp
- /__w/clio/clio/src/feed/impl/SingleFeedBase.cpp