[][src]Struct futures_intrusive::channel::GenericOneshotBroadcastChannel

pub struct GenericOneshotBroadcastChannel<MutexType: RawMutex, T> { /* fields omitted */ }

A channel which can be used to exchange a single value between two or more concurrent tasks.

The value which gets sent will get stored inside the Channel, and can be retrieved by an arbitrary number of tasks afterwards.

Tasks can wait for the value to get delivered via receive. The returned Future will get fulfilled when a value is sent into the channel.

Methods

impl<MutexType: RawMutex, T> GenericOneshotBroadcastChannel<MutexType, T> where
    T: Clone
[src]

pub fn new() -> GenericOneshotBroadcastChannel<MutexType, T>[src]

Creates a new OneshotBroadcastChannel in the given state

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

Writes a single value to the channel.

This will notify waiters about the availability of the value. If a value had been written to the channel before, or if the channel is closed, the new value will be rejected and returned inside the error variant.

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

Closes the channel.

This will notify waiters about closure, by fulfilling pending Futures with None. send(value) attempts which follow this call will fail with a ChannelSendError.

pub fn receive(&self) -> ChannelReceiveFuture<MutexType, T>[src]

Returns a future that gets fulfilled when a value is written to the channel or the channel is closed.

Trait Implementations

impl<MutexType: RawMutex, T> Debug for GenericOneshotBroadcastChannel<MutexType, T>[src]

impl<MutexType: RawMutex + Send, T: Send> Send for GenericOneshotBroadcastChannel<MutexType, T>[src]

impl<MutexType: RawMutex + Sync, T: Send> Sync for GenericOneshotBroadcastChannel<MutexType, T>[src]

Auto Trait Implementations

impl<MutexType, T> !RefUnwindSafe for GenericOneshotBroadcastChannel<MutexType, T>

impl<MutexType, T> Unpin for GenericOneshotBroadcastChannel<MutexType, T> where
    MutexType: Unpin,
    T: Unpin

impl<MutexType, T> UnwindSafe for GenericOneshotBroadcastChannel<MutexType, T> where
    MutexType: UnwindSafe,
    T: UnwindSafe

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, 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.