Struct ChannelCore 

pub struct ChannelCore { /* private fields */ }

Shared state between a Tx/Rx pair created by channel().

Contains a Mutex<Option<ChannelBinding>> that is written once during binding and read/taken by the paired handle. The mutex is only locked during binding (once) and on first use by the paired handle (once).

Implementations

impl ChannelCore

pub fn set_binding(&self, binding: ChannelBinding)

Store a binding in the core. Panics if already set.

pub fn get_sink(&self) -> Option<Arc<dyn ChannelSink>>

Clone the sink from the core (for Tx reading the sink). Returns None if no sink has been set or if the binding is a Receiver.

pub fn take_receiver(&self) -> Option<Receiver<IncomingChannelMessage>>

Take the receiver out of the core (for Rx on first recv). Returns None if no receiver has been set or if it was already taken.