Struct Hub 

pub struct Hub<T: DataDeliveryPolicy + Clone> { /* private fields */ }

Sync data communcation hub to implement in-process pub/sub model for thread workers

Implementations

impl<T: DataDeliveryPolicy + Clone> Hub<T>

pub fn new() -> Self

Creates a new hub with default settings

pub fn set_default_channel_capacity(self, capacity: usize) -> Self

Sets the default client channel capacity (the default is 1024), can be used as a build pattern

pub fn send(&self, message: T)

Sends a message to subscribed clients, ignores send errors

Panics

Should not panic

pub fn send_checked<F>(&self, message: T, error_handler: F) -> Result<()>

where F: Fn(&str, &Error) -> bool,

Sends a message to subscribed clients, calls an error handlers function in case of errors with some subsciber

If the error function returns false, the whole operation is aborted

Panics

Should not panic

pub fn sender(&self) -> Client<T>

Registers a sender-only client with no subscriptions

If attempting to receive a message from such client, Error::ChannelClosed is returned

pub fn register<F>(&self, name: &str, condition: F) -> Result<Client<T>>

where F: Fn(&T) -> bool + Send + Sync + 'static,

Registers a regular client. The condition function is used to check which kinds of messages should be delivered (returns true for subscribed)

pub fn register_with_options( &self, client_options: ClientOptions<T>, ) -> Result<Client<T>>

Registers a regular client with custom options

Trait Implementations

impl<T: DataDeliveryPolicy + Clone> Clone for Hub<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> DataChannel<T> for Hub<T>

where T: DataDeliveryPolicy + Clone,

fn send(&self, message: T) -> Result<()>

Sends a value to the channel

fn recv(&self) -> Result<T>

Receives a value from the channel

fn try_recv(&self) -> Result<T>

Tries to receive a value from the channel (non-blocking)

fn try_send(&self, _message: T) -> Result<()>

Tries to send a value to the channel (non-blocking)

fn is_alive(&self) -> bool

Returns true if the channel is alive

impl<T: DataDeliveryPolicy + Clone> Default for Hub<T>

fn default() -> Self

Returns the “default value” for a type.