Struct AquaReceiver

pub struct AquaReceiver<T> {
    receiver: Receiver<T>,
}

Fields

receiver: Receiver<T>

Implementations

impl<T> AquaReceiver<T>

pub fn recv(&mut self) -> Result<T, AquaChannelError>

Receive a value from a channel (blocking), and on builds with “debug_channel” feature enabled, count each call for each receiver

pub fn try_recv(&mut self) -> Result<T, AquaChannelError>

Receive a value from a channel (non-blocking), and on builds with “debug_channel” feature enabled, count each call for each receiver