Struct station::pubsub::Subscriber

pub struct Subscriber { /* fields omitted */ }

The Subscriber receives messages of type T and processes them with a callback.

Implementations

impl Subscriber

pub fn with_udp_port<T>(
    name: &'static str,
    port: u16,
    callback: Box<dyn Send + Fn(T)>
) -> Subscriber where
    T: Debug + DeserializeOwned + Serialize + 'static, 

Create a subscriber that listens on a UDP port.

Args:

• name The name to refer to the subscriber.
• port: The UDP port to listen for new messages on.
• callback: The function to call on incoming data.

pub fn with_unix_datagram<T>(
    name: &'static str,
    path: &str,
    callback: Box<dyn Send + Fn(T)>
) -> Subscriber where
    T: Debug + DeserializeOwned + Serialize + 'static, 

Create a subscriber that listens on a Unix Datagram socket.

Args:

• name The name to refer to the subscriber.
• path: The unix socket path to bind the server to.
• callback: The function to call on incoming data.

pub fn is_running(&self) -> bool

Check if the Subscriber is running.

pub fn stop(&mut self)

Stop the Subscriber

Trait Implementations

impl Drop for Subscriber

fn drop(&mut self)

Executes the destructor for this type.