futures_intrusive::channel

Struct ChannelSendFuture

Source
pub struct ChannelSendFuture<'a, MutexType, T> { /* private fields */ }
Expand description

A Future that is returned by the send function on a channel. The future gets resolved with None when a value could be written to the channel. If the channel gets closed the send operation will fail, and the Future will resolve to ChannelSendError(T) and return the item to send.

Implementations§

Source§

impl<'a, MutexType, T> ChannelSendFuture<'a, MutexType, T>

Source

pub fn cancel(&mut self) -> Option<T>

Tries to cancel the ongoing send operation

Trait Implementations§

Source§

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

Source§

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

Formats the value using the given formatter. Read more
Source§

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

Source§

fn drop(&mut self)

Executes the destructor for this type. Read more
Source§

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

Source§

fn is_terminated(&self) -> bool

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

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

Source§

type Output = Result<(), ChannelSendError<T>>

The type of value produced on completion.
Source§

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

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available. Read more
Source§

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

Auto Trait Implementations§

§

impl<'a, MutexType, T> Freeze for ChannelSendFuture<'a, MutexType, T>
where T: Freeze,

§

impl<'a, MutexType, T> !RefUnwindSafe for ChannelSendFuture<'a, MutexType, T>

§

impl<'a, MutexType, T> !Sync for ChannelSendFuture<'a, MutexType, T>

§

impl<'a, MutexType, T> !Unpin for ChannelSendFuture<'a, MutexType, T>

§

impl<'a, MutexType, T> !UnwindSafe for ChannelSendFuture<'a, MutexType, T>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<F> IntoFuture for F
where F: Future,

Source§

type Output = <F as Future>::Output

The output that the future will produce on completion.
Source§

type IntoFuture = F

Which kind of future are we turning this into?
Source§

fn into_future(self) -> <F as IntoFuture>::IntoFuture

Creates a future from a value. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<F, T, E> TryFuture for F
where F: Future<Output = Result<T, E>> + ?Sized,

Source§

type Ok = T

The type of successful values yielded by this future
Source§

type Error = E

The type of failures yielded by this future
Source§

fn try_poll( self: Pin<&mut F>, cx: &mut Context<'_>, ) -> Poll<<F as Future>::Output>

Poll this TryFuture as if it were a Future. Read more
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

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

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.