Struct Consumer

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

Fifo Consumption Handle

Implementations

impl<T> Consumer<T>

pub fn try_recv_into(&self, storage: &mut dyn Storage<T>) -> usize

Tries to receive some items into custom storage.

pub fn try_recv_many(&self) -> Vec<T>

Tries to receive as many items as possible, into a vector.

pub fn try_recv_exact<const N: usize>(&self) -> Option<[T; N]>

Tries to receive exactly N items into an array.

pub fn try_recv(&self) -> Option<T>

Tries to receive one item.

pub fn insert_waker(&self, waker: Box<Waker>)

Sets the waker of the current task, to be woken up when new items are available.

pub fn take_waker(&self) -> Option<Box<Waker>>

Tries to take back a previously inserted waker.

impl<T: Unpin> Consumer<T>

pub fn recv_into<S: AsyncStorage<T>>(&self, storage: S) -> Recv<'_, S, T>

Receives some items into custom storage, asynchronously.

pub fn recv_many(&self) -> Recv<'_, Vec<T>, T>

Receives as many items as possible, into a vector, asynchronously.

pub fn recv_exact<const N: usize>(&self) -> RecvExact<'_, N, T>

Receives exactly N items into an array, asynchronously.

pub fn recv(&self) -> RecvOne<'_, T>

Receives one item, asynchronously.

impl<T: Unpin> Consumer<T>

pub fn recv_into_blocking<S: AsyncStorage<T>>(&self, storage: S) -> S::Output

Receives some items into custom storage, blocking.

This method is only available if you enable the blocking feature.

pub fn recv_many_blocking(&self) -> Vec<T>

Receives as many items as possible, into a vector, blocking.

This method is only available if you enable the blocking feature.

pub fn recv_exact_blocking<const N: usize>(&self) -> [T; N]

Receives exactly N items into an array, blocking.

This method is only available if you enable the blocking feature.

pub fn recv_blocking(&self) -> T

Receives one item, blocking.

This method is only available if you enable the blocking feature.

Trait Implementations

impl<T> Send for Consumer<T>

impl<T> Sync for Consumer<T>