Struct BufferedReceiver 

pub struct BufferedReceiver<'a, T: Send> { /* private fields */ }

A wrapper around a Receiver that returns RecycledVecs to automatically return buffers to the BufferedChannel pool.

Implementations

impl<'a, T: Send> BufferedReceiver<'a, T>

pub async fn recv(&self) -> Result<RecycledVec<'_, T>, RecvError>

Receive a message asynchronously.

The returned RecycledVec will automatically return the buffer to the pool when dropped.

pub fn recv_blocking(&self) -> Result<RecycledVec<'_, T>, RecvError>

Receive a message blocking.

The returned RecycledVec will automatically return the buffer to the pool when dropped.

Trait Implementations

impl<'a, T: Send> Clone for BufferedReceiver<'a, T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.