Trait DataChannel 

pub trait DataChannel<T> {
    // Required methods
    fn send(&self, value: T) -> Result<(), Error>;
    fn try_send(&self, value: T) -> Result<(), Error>;
    fn recv(&self) -> Result<T, Error>;
    fn try_recv(&self) -> Result<T, Error>;

    // Provided method
    fn is_alive(&self) -> bool { ... }
}

An abstract trait for data channels and hubs

Required Methods

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

Sends a value to the channel

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

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

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

Receives a value from the channel

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

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

Provided Methods

fn is_alive(&self) -> bool

Returns true if the channel is alive

Implementors

impl<T> DataChannel<T> for Client<T>

where T: DataDeliveryPolicy + Clone,

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

where T: DataDeliveryPolicy + Clone,

impl<T, S, M, CV> DataChannel<T> for BaseReceiver<T, S, M, CV>

where S: ChannelStorage<T>, M: RawMutex, CV: RawCondvar<RawMutex = M> + RawCondvar,

impl<T, S, M, CV> DataChannel<T> for BaseSender<T, S, M, CV>

where S: ChannelStorage<T>, M: RawMutex, CV: RawCondvar<RawMutex = M> + RawCondvar,