async_trait is no longer needed

Author: frostyplanet

Cargo.toml

@@ -20,7 +20,6 @@ rust-version = "1.61"
 crossbeam = "0.8"
 futures = "0.3"
 enum_dispatch = "0.3"
-async-trait = "0"
 parking_lot = "0"
 tokio = { version = "1", features = ["time"], optional=true }
 async-std = {version = "1", optional=true}

src/async_rx.rs

@@ -1,6 +1,5 @@
 use crate::channel::*;
 use crate::stream::AsyncStream;
-use async_trait::async_trait;
 use crossbeam::channel::Receiver;
 #[cfg(feature = "tokio")]
 pub use crossbeam::channel::RecvTimeoutError;
@@ -341,7 +340,6 @@ impl<T> Future for ReceiveTimeoutFuture<'_, T> {
 }
 
 /// For writing generic code with MAsyncRx & AsyncRx
-#[async_trait]
 pub trait AsyncRxTrait<T: Unpin + Send + 'static>: Send + 'static {
     /// Receive message, will await when channel is empty.
     ///
@@ -385,7 +383,6 @@ pub trait AsyncRxTrait<T: Unpin + Send + 'static>: Send + 'static {
     fn get_waker_size(&self) -> (usize, usize);
 }
 
-#[async_trait]
 impl<T: Unpin + Send + 'static> AsyncRxTrait<T> for AsyncRx<T> {
     #[inline(always)]
     fn recv<'a>(&'a self) -> ReceiveFuture<'a, T> {
@@ -476,7 +473,6 @@ impl<T> DerefMut for MAsyncRx<T> {
     }
 }
 
-#[async_trait]
 impl<T: Unpin + Send + 'static> AsyncRxTrait<T> for MAsyncRx<T> {
     #[inline(always)]
     fn try_recv(&self) -> Result<T, TryRecvError> {

src/async_tx.rs

@@ -1,5 +1,4 @@
 use crate::channel::*;
-use async_trait::async_trait;
 #[cfg(feature = "tokio")]
 pub use crossbeam::channel::SendTimeoutError;
 use crossbeam::channel::Sender;
@@ -338,7 +337,6 @@ impl<T: Unpin + Send + 'static> Future for SendTimeoutFuture<'_, T> {
 }
 
 /// For writing generic code with MAsyncTx & AsyncTx
-#[async_trait]
 pub trait AsyncTxTrait<T: Unpin + Send + 'static>: Send + 'static {
     /// Just for debugging purpose, to monitor queue size
     #[cfg(test)]
@@ -383,7 +381,6 @@ pub trait AsyncTxTrait<T: Unpin + Send + 'static>: Send + 'static {
     ) -> SendTimeoutFuture<'a, T>;
 }
 
-#[async_trait]
 impl<T: Unpin + Send + 'static> AsyncTxTrait<T> for AsyncTx<T> {
     #[inline(always)]
     #[cfg(test)]
@@ -462,7 +459,6 @@ impl<T> DerefMut for MAsyncTx<T> {
     }
 }
 
-#[async_trait]
 impl<T: Unpin + Send + 'static> AsyncTxTrait<T> for MAsyncTx<T> {
     #[inline(always)]
     fn try_send(&self, item: T) -> Result<(), TrySendError<T>> {