Struct tokio::sync::broadcast::Recv

struct Recv<'a, T> {
    receiver: &'a mut Receiver<T>,
    waiter: UnsafeCell<Waiter>,
}

Receive a value future.

Fields

receiver: &'a mut Receiver<T>

Receiver being waited on.

waiter: UnsafeCell<Waiter>

Entry in the waiter LinkedList.

Implementations

impl<'a, T> Recv<'a, T>

fn new(receiver: &'a mut Receiver<T>) -> Recv<'a, T>

fn project(self: Pin<&mut Self>) -> (&mut Receiver<T>, &UnsafeCell<Waiter>)

A custom project implementation is used in place of pin-project-lite as a custom drop implementation is needed.

Trait Implementations

impl<'a, T> Drop for Recv<'a, T>

fn drop(&mut self)

Executes the destructor for this type.

impl<'a, T> Future for Recv<'a, T>

where T: Clone,

type Output = Result<T, RecvError>

The type of value produced on completion.

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

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

impl<'a, T: Send> Send for Recv<'a, T>

impl<'a, T: Send> Sync for Recv<'a, T>