Struct futures_intrusive::channel::shared::GenericSender

pub struct GenericSender<MutexType, T> where
    MutexType: RawMutex,
    T: 'static,  { /* fields omitted */ }

The sending side of a channel which can be used to exchange values between concurrent tasks.

Values can be sent into the channel through send. The returned Future will get resolved when the value has been stored inside the channel.

Methods

impl<MutexType, T> GenericSender<MutexType, T> where
    MutexType: RawMutex + 'static, 

Important traits for ChannelSendFuture<MutexType, T>

impl<MutexType, T> Future for ChannelSendFuture<MutexType, T> type Output = Result<(), ChannelSendError<T>>;

pub fn send(&self, value: T) -> ChannelSendFuture<MutexType, T>

Returns a future that gets fulfilled when the value has been written to the channel. If the channel gets closed while the send is in progress, sending the value will fail, and the future will deliver the value back.

pub fn close(&self)

Closes the channel. All pending future send attempts will fail. Receive attempts will continue to succeed as long as there are items stored inside the channel. Further attempts will return None.

Trait Implementations

impl<MutexType, T> Drop for GenericSender<MutexType, T> where
    MutexType: RawMutex, 

fn drop(&mut self)

Executes the destructor for this type.

impl<MutexType, T> Clone for GenericSender<MutexType, T> where
    MutexType: RawMutex, 

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<MutexType, T> Debug for GenericSender<MutexType, T> where
    MutexType: RawMutex, 

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

Formats the value using the given formatter.