Struct flume::WeakSender

source ·
pub struct WeakSender<T> { /* private fields */ }
Expand description

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§

source§

impl<T> WeakSender<T>

source

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.

Auto Trait Implementations§

§

impl<T> RefUnwindSafe for WeakSender<T>

§

impl<T> Send for WeakSender<T>
where T: Send,

§

impl<T> Sync for WeakSender<T>
where T: Send,

§

impl<T> Unpin for WeakSender<T>

§

impl<T> UnwindSafe for WeakSender<T>

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.