Enum Stealer

pub enum Stealer<T> {
    Owner(Vec<T>),
    Taker(StealHandle<T>),
}

Stealers swap out and take ownership of buffers in entirety from Workers

Variants

Owner(Vec<T>)

Stealer was created with an owned batch that can simply be unwrapped

Taker(StealHandle<T>)

A Steal Handle buffer swaps either by taking the buffer directly or by awaiting the Worker to send on write completion

Implementations

impl<T> Stealer<T>

pub async fn take(self) -> Vec<T>

Take the entire queue by swapping the underlying buffer and converting back into a Vec<T> or by waiting to receive the buffer from the Worker if a write was in progress.

pub fn take_blocking(self) -> Vec<T>

Take the entire queue by swapping the underlying buffer and converting into a Vec<T> or by blocking to receive from the Worker if a write was in progress. This is always non-blocking when called on the same thread as the Worker

Trait Implementations

impl<T> Debug for Stealer<T>

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

Formats the value using the given formatter.

impl<T> From<Stealer<T>> for Vec<T>

Uses Stealer::take_blocking; non-blocking when called on the same thread as Worker

fn from(stealer: Stealer<T>) -> Self

Converts to this type from the input type.

impl<T: Send> Send for Stealer<T>

impl<T: Send> Sync for Stealer<T>