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

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

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

Tasks can receive values from the channel through the receive method. The returned Future will get resolved when a value is sent into the channel.

Methods

impl<MutexType, T> GenericStateReceiver<MutexType, T> where
    MutexType: RawMutex + 'static,
    T: Clone
[src]

pub fn receive(&self, state_id: StateId) -> StateReceiveFuture<MutexType, T>[src]

Returns a future that gets fulfilled when a value is written to the channel or the channel is closed. state_id specifies the minimum state ID that should be retrieved by the receive operation.

The returned StateReceiveFuture will get fulfilled with the retrieved value as well as the StateId which is required to retrieve the following state

pub fn try_receive(&self, state_id: StateId) -> Option<(StateId, T)>[src]

Attempt to retrieve a value whose StateId is greater than the one provided.

Returns None if no value is found in the channel, or if the current StateId of the value is less or equal to the one provided.

Trait Implementations

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

impl<MutexType, T> Debug for GenericStateReceiver<MutexType, T> where
    MutexType: RawMutex,
    T: Clone
[src]

impl<MutexType, T> Drop for GenericStateReceiver<MutexType, T> where
    MutexType: RawMutex,
    T: Clone
[src]

Auto Trait Implementations

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

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

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

impl<MutexType, T> Unpin for GenericStateReceiver<MutexType, T>

impl<MutexType, T> !UnwindSafe for GenericStateReceiver<MutexType, T>

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.