Struct flume::WeakSender

pub struct WeakSender<T> { /* private fields */ }

A sender that does not prevent the channel from being closed.

Weak senders do not count towards the number of active senders on the channel. As soon as all normal Senders are dropped, the channel is closed, even if there is still a WeakSender.

To send messages, a WeakSender must first be upgraded to a Sender using the [upgrade] method.

Implementations

impl<T> WeakSender<T>

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

Tries to upgrade the WeakSender to a Sender, in order to send messages.

Returns None if the channel was closed already. Note that a Some return value does not guarantee that the channel is still open.