1 2 3 4 5 6 7 8 9 10 11
use crate::error::TryRecvError; // #[async_trait::async_trait] pub trait AsyncReceiver<T> { async fn recv(&mut self) -> Option<T> where T: Send; fn try_recv(&mut self) -> Result<T, TryRecvError>; }