Struct AsyncWorkerReceiver 

pub struct AsyncWorkerReceiver<T> { /* private fields */ }

Receiver/stream adapter backed by a dedicated dequeue worker thread.

Implementations

impl<T: Send + 'static> AsyncWorkerReceiver<T>

pub fn new(scheduler: AsyncScheduler<T>, buffer: usize) -> Self

Creates a new worker-backed receiver.

pub async fn recv(&mut self) -> Option<DequeueItem<T>>

Waits for the next task, returning None once the worker stops.

Trait Implementations

impl<T> Drop for AsyncWorkerReceiver<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T> Stream for AsyncWorkerReceiver<T>

type Item = DequeueItem<T>

Values yielded by the stream.

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

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.