Struct BufferedReceiver

pub struct BufferedReceiver {
    pub rx: Receiver<Box<dyn Any>>,
    pub buf: Dfb,
}

Wraps an mpsc::Receiver to support dynamic typing and buffered results.

Fields

rx: Receiver<Box<dyn Any>>

buf: Dfb

Implementations

impl BufferedReceiver

pub fn recv_until<T: 'static>(&mut self) -> Result<T, AnyRecvError>

Wraps mpsc::Receiver::recv. See [BufRecvError] for details on the return value. Will continuously recv until the supplied type is found. Any unmatching types received will be placed in the buffer.

pub fn recv<T: 'static>(&mut self) -> Result<T, AnyRecvError>

Wraps mpsc::Receiver::recv. See [BufRecvError] for details on the return value. Will attempt to take from the internal buffer before performing an actual channel recv.

pub fn recv_live<T: 'static>(&mut self) -> Result<T, AnyRecvError>

Wraps mpsc::Receiver::recv. See [BufRecvError] for details on the return value. Will perform a channel recv regardless of whether or not anything is contained in the buffer.

pub fn recv_timeout<T: 'static>( &mut self, timeout: Duration, ) -> Result<T, AnyRecvError>

Wraps mpsc::Receiver::recv_timeout. See [BufRecvError] for details on the return value. Will attempt to take from the internal buffer before performing an actual channel recv_timeout.

pub fn recv_timeout_live<T: 'static>( &mut self, timeout: Duration, ) -> Result<T, AnyRecvError>

Wraps mpsc::Receiver::recv_timeout. See [BufRecvError] for details on the return value. Will perform a channel recv_timeout regardless of whether or not anything is contained in the buffer.

pub fn try_recv<T: 'static>(&mut self) -> Result<T, AnyRecvError>

Wraps mpsc::Receiver::try_recv. See [BufRecvError] for details on the return value. Will attempt to take from the internal buffer before performing an actual channel recv_timeout.

pub fn try_recv_live<T: 'static>(&mut self) -> Result<T, AnyRecvError>

Wraps mpsc::Receiver::try_recv. See [BufRecvError] for details on the return value. Will perform a channel recv_timeout regardless of whether or not anything is contained in the buffer.

pub fn recv_nobuf<T: 'static>(&self) -> Result<T, AnyRecvError>

Wraps mpsc::Receiver::recv. See crate::AnyRecvError for details on the return value. Bypasses the buffer entirely.

pub fn recv_timeout_nobuf<T: 'static>( &self, timeout: Duration, ) -> Result<T, AnyRecvError>

Wraps mpsc::Receiver::recv_timeout. See crate::AnyRecvError for details on the return value. Bypasses the buffer entirely.

pub fn try_recv_nobuf<T: 'static>(&self) -> Result<T, AnyRecvError>

Wraps mpsc::Receiver::try_recv. See crate::AnyRecvError for details on the return value. Bypasses the buffer entirely.

pub fn recv_buf<T: 'static>(&mut self) -> Result<T, AnyRecvError>

Will attempt to read a value from the internal buffer. Will not do a channel recv of any kind even if the buffer is empty.

Trait Implementations

impl Debug for BufferedReceiver

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

Formats the value using the given formatter.

impl Send for BufferedReceiver