ark::gui::PluginSubscriberBridge
Defined in header “ark/gui/plugin_subscriber.hh”.
This class wraps pipeline subscribers, allowing you to deserialize incoming messages (bytes) and push them onto subscribers, without knowing the type.
Typedefs
- using SubscriberPtr = std::shared_ptr< pipeline::Subscriber< Type > >
Methods
-
PluginSubscriberBridge(SubscriberPtr subscriber, SubscriberConfiguration< Type > config)
Constructor. Initializes against a subscriber. -
const std::string & channel_name()
Returns the channel name of this subscriber. -
PluginSubscriberConnectionConfig connection_config()
Returns connection-specific configuration about this subscriber. -
void process_message(const core::ByteBuffer & buffer, uint64_t sequence_number)
Deserializes the incoming byte buffer, as if it was represented by the owning type of this producer.