Struct WeakSender 

pub struct WeakSender<T: Send + Sync + 'static> { /* private fields */ }

A sender that does not keep the channel open.

Made by Sender::downgrade. Once every Sender is gone the channel is closed, whatever WeakSenders are left. A WeakSender sends nothing itself: upgrade makes a Sender of it while one exists.

use nuclei::sync::broadcast;

let (tx, _rx) = broadcast::channel::<u8>(4);
let weak = tx.downgrade();
assert!(weak.upgrade().is_some());
drop(tx);
assert!(weak.upgrade().is_none());

Implementations

impl<T: Send + Sync + 'static> WeakSender<T>

pub fn upgrade(&self) -> Option<Sender<T>>

A Sender of the channel, while one exists; None once the last is gone (the channel is closed then, for good).

pub fn strong_count(&self) -> usize

How many Senders exist.

pub fn weak_count(&self) -> usize

How many WeakSenders exist.

Trait Implementations

impl<T: Send + Sync + 'static> Clone for WeakSender<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: Send + Sync + 'static> Debug for WeakSender<T>

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

Formats the value using the given formatter.

impl<T: Send + Sync + 'static> Drop for WeakSender<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.