Struct futures_intrusive::channel::ChannelReceiveFuture

pub struct ChannelReceiveFuture<'a, MutexType, T> { /* private fields */ }

A Future that is returned by the receive function on a channel. The future gets resolved with Some(value) when a value could be received from the channel. If the channels gets closed and no items are still enqueued inside the channel, the future will resolve to None.

Trait Implementations

impl<'a, MutexType, T> Debug for ChannelReceiveFuture<'a, MutexType, T>

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

Formats the value using the given formatter.

impl<'a, MutexType, T> Drop for ChannelReceiveFuture<'a, MutexType, T>

fn drop(&mut self)

Executes the destructor for this type.

impl<'a, MutexType, T> FusedFuture for ChannelReceiveFuture<'a, MutexType, T>

fn is_terminated(&self) -> bool

Returns true if the underlying future should no longer be polled.

impl<'a, MutexType, T> Future for ChannelReceiveFuture<'a, MutexType, T>

type Output = Option<T>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T>>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<'a, MutexType: Sync, T: Send> Send for ChannelReceiveFuture<'a, MutexType, T>