Struct swap_queue::Stealer

pub struct Stealer<T> { /* fields omitted */ }

For every buffer swapped in a stealer is issued that can later swap out and take ownership of that buffer

Implementations

impl<T> Stealer<T>

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

Take the entire queue via swapping the underlying buffer and converting into a Vec<T>

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

Take the entire queue via swapping the underlying buffer and converting into a Vec<T>, blocking only if write in progress. This is always non-blocking if never moved to a new thread.

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>

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

Performs the conversion.

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

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