Trait ChannelRecv 

pub trait ChannelRecv<T>: Send + Sync {
    // Required method
    fn try_recv(&self) -> RecvOutcome<T>;
}

Common receiver interface (non-blocking).

use daedalus_core::channels::{bounded, ChannelRecv, RecvOutcome};
let (_tx, rx) = bounded::<u8>(1);
assert_eq!(rx.try_recv(), RecvOutcome::Empty);

Required Methods

fn try_recv(&self) -> RecvOutcome<T>

Implementors

impl<T: Send + Sync> ChannelRecv<Arc<T>> for BroadcastReceiver<T>

impl<T: Send + Sync> ChannelRecv<Arc<T>> for NewestReceiver<T>

impl<T: Send> ChannelRecv<T> for BoundedReceiver<T>

impl<T: Send> ChannelRecv<T> for UnboundedReceiver<T>