1 2 3 4 5 6 7 8 9
use core::future::Future; use crate::error::{OneshotRecvError, TryRecvError}; // #[async_trait::async_trait] pub trait AsyncReceiver<T>: Future<Output = Result<T, OneshotRecvError>> { fn try_recv(&mut self) -> Result<T, TryRecvError>; }