[][src]Struct futures_intrusive::channel::shared::GenericSender

pub struct GenericSender<MutexType, T, A> where
    MutexType: RawMutex,
    A: RingBuf<Item = T>,
    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, A> GenericSender<MutexType, T, A> where
    MutexType: 'static + RawMutex,
    A: 'static + RingBuf<Item = T>, 
[src]

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

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 try_send(&self, value: T) -> Result<(), TrySendError<T>>[src]

Attempt to send the value without waiting.

This operation is not supported for unbuffered channels and will panic if the capacity of the RingBuf is zero. The reason for this is that the actual value transfer on unbuffered channels always happens when a receiving task copies the value out of the sending task while it is waiting. If the sending task does not wait, the value can not be transferred. Since this method can therefore never yield a reasonable result with unbuffered channels, it panics in order to highlight the use of an inappropriate API.

pub fn close(&self) -> CloseStatus[src]

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, A> Clone for GenericSender<MutexType, T, A> where
    MutexType: RawMutex,
    A: RingBuf<Item = T>, 
[src]

impl<MutexType, T, A> Debug for GenericSender<MutexType, T, A> where
    MutexType: RawMutex,
    A: RingBuf<Item = T>, 
[src]

impl<MutexType, T, A> Drop for GenericSender<MutexType, T, A> where
    MutexType: RawMutex,
    A: RingBuf<Item = T>, 
[src]

Auto Trait Implementations

impl<MutexType, T, A> !RefUnwindSafe for GenericSender<MutexType, T, A>

impl<MutexType, T, A> Send for GenericSender<MutexType, T, A> where
    A: Send,
    MutexType: Send + Sync,
    T: Send

impl<MutexType, T, A> Sync for GenericSender<MutexType, T, A> where
    A: Send,
    MutexType: Send + Sync,
    T: Send

impl<MutexType, T, A> Unpin for GenericSender<MutexType, T, A>

impl<MutexType, T, A> !UnwindSafe for GenericSender<MutexType, T, A>

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

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

The type returned in the event of a conversion error.