Struct PubSub

pub struct PubSub { /* private fields */ }

A handle to the PubSub connection.

Implementations

impl PubSub

pub fn listen(url: &str) -> Result<Self, Error>

Listens on the given URL and returns a PubSub handle.

The URL must be in the format tcp://127.0.0.1:{port}, where port can be 0 to let the OS assign an available port.

Examples

let pubsub = elixirkit::PubSub::listen("tcp://127.0.0.1:0")
    .expect("failed to listen");

pub fn url(&self) -> String

Returns the URL for this PubSub connection.

pub fn subscribe<F>(&self, topic: &str, callback: F)

where F: Fn(&[u8]) + Send + 'static,

Subscribes to messages on the given topic from the Elixir side.

pub fn broadcast(&self, topic: &str, message: &[u8]) -> Result<()>

Broadcasts a message on the given topic to the Elixir side.

Trait Implementations

impl Clone for PubSub

fn clone(&self) -> PubSub

Returns a copy of the value.

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

Performs copy-assignment from source.