Enum ChannelData 

pub enum ChannelData {
    Sender {
        tx: Arc<Sender<ValueWord>>,
        closed: Arc<AtomicBool>,
    },
    Receiver {
        rx: Arc<Mutex<Receiver<ValueWord>>>,
        closed: Arc<AtomicBool>,
    },
}

MPSC channel endpoint (sender or receiver).

A Channel() call creates a sender/receiver pair. Both share the same underlying mpsc::channel. The sender can be cloned (multi-producer), while the receiver is wrapped in a Mutex for shared access.

Variants

Sender

Fields

tx: Arc<Sender<ValueWord>>

closed: Arc<AtomicBool>

Receiver

Fields

rx: Arc<Mutex<Receiver<ValueWord>>>

closed: Arc<AtomicBool>

Implementations

impl ChannelData

pub fn new_pair() -> (Self, Self)

Create a new sender/receiver pair.

pub fn is_closed(&self) -> bool

Check if the channel is closed.

pub fn close(&self)

Close the channel.

pub fn is_sender(&self) -> bool

Whether this is the sender end.

Trait Implementations

impl Clone for ChannelData

fn clone(&self) -> ChannelData

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChannelData

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.