Struct station::pubsub::Publisher

pub struct Publisher<T> { /* fields omitted */ }

The Publisher publishes messages of type T to its subscribers.

Implementations

impl<T> Publisher<T> where
    T: DeserializeOwned + Serialize, 

pub fn new(name: &str) -> Publisher<T>

Create a new publisher with a name.

Args:

• name: The name of the publisher.

pub fn publish(&mut self, message: &T)

Publish a message to the subscribers.

By default, the publisher has no subscribers. Subscribers must be added before the publish method does anything. Without subscribers, publish is a no-op.

pub fn add_udp_endpoint(&mut self, addr: SocketAddr) -> bool

Add a UDP endpoint to publish to.

Args:

• addr: The address of the UDP endpoint.

pub fn add_unix_datagram_endpoint(&mut self, path: &Path) -> bool

Add a Unix Datagram endpoint to publish to.

Args:

• path: The Unix socket path to publish to.

pub fn num_endpoints(&self) -> usize

Return the total number of Publish endpoints.