Struct InnerListener 

pub(crate) struct InnerListener<T, B>
where
    B: Unpin + Borrow<Inner<T>>,
{
    pub(crate) event: B,
    pub(crate) listener: Option<Listener<T>>,
}

Fields

event: B

listener: Option<Listener<T>>

Implementations

impl<T, B: Borrow<Inner<T>> + Unpin> InnerListener<T, B>

pub(crate) fn listen(self: Pin<&mut Self>)

Insert this listener into the linked list.

pub(crate) fn wait_internal( self: Pin<&mut Self>, deadline: Option<Instant>, ) -> Option<T>

Wait until the provided deadline.

pub(crate) fn wait_with_parker( self: Pin<&mut Self>, deadline: Option<Instant>, parker: &Parker, unparker: TaskRef<'_>, ) -> Option<T>

Wait until the provided deadline using the specified parker/unparker pair.

pub(crate) fn discard(self: Pin<&mut Self>) -> bool

Drops this listener and discards its notification (if any) without notifying another active listener.

pub(crate) fn poll_internal( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<T>

Poll this listener for a notification.

Trait Implementations

impl<T, B> Drop for InnerListener<T, B>

where B: Unpin + Borrow<Inner<T>>,

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Send, B: Borrow<Inner<T>> + Unpin + Send> Send for InnerListener<T, B>

impl<T: Send, B: Borrow<Inner<T>> + Unpin + Sync> Sync for InnerListener<T, B>