add try_send

Author: rob-maron

src/channel/bounded.rs

@@ -47,7 +47,7 @@ mod inner {
 /// inner module, used to group feature-specific imports
 #[cfg(async_channel_impl = "flume")]
 mod inner {
-    pub use flume::{RecvError, SendError, TryRecvError};
+    pub use flume::{RecvError, SendError, TryRecvError, TrySendError};
 
     use flume::{r#async::RecvStream, Receiver as InnerReceiver, Sender as InnerSender};
 
@@ -77,7 +77,7 @@ mod inner {
 /// inner module, used to group feature-specific imports
 #[cfg(not(any(async_channel_impl = "flume", async_channel_impl = "tokio")))]
 mod inner {
-    pub use async_std::channel::{RecvError, SendError, TryRecvError};
+    pub use async_std::channel::{RecvError, SendError, TryRecvError, TrySendError};
 
     use async_std::channel::{Receiver as InnerReceiver, Sender as InnerSender};
 
@@ -121,6 +121,20 @@ impl<T> Sender<T> {
 
         result
     }
+
+    /// Try to send a value over the channel. Will return immediately if the channel is full.
+    ///
+    /// # Errors
+    /// - If the channel is full
+    /// - If the channel is dropped
+    pub async fn try_send(&self, msg: T) -> Result<(), TrySendError<T>> {
+        #[cfg(async_channel_impl = "flume")]
+        let result = self.0.try_send(msg);
+        #[cfg(not(all(async_channel_impl = "flume")))]
+        let result = self.0.try_send(msg).await;
+
+        result
+    }
 }
 
 impl<T> Receiver<T> {