Struct EventPublisher 

pub struct EventPublisher { /* private fields */ }

Cloneable sender handle used by actors to publish MQTT-like events.

Implementations

impl EventPublisher

pub fn channel() -> (Self, UnboundedReceiver<(String, Vec<u8>)>)

Create a linked (publisher, receiver) pair.

pub fn publish<T: Serialize>(&self, topic: impl Into<String>, payload: &T)

Publish a serialisable value to topic.

pub fn publish_raw(&self, topic: impl Into<String>, payload: Vec<u8>)

Publish raw bytes.

Trait Implementations

impl Clone for EventPublisher

fn clone(&self) -> EventPublisher

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EventPublisher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.