Version update

Signed-off-by: Heinz N. Gies <heinz@licenser.net>
tremor-rs · Oct 31, 2023 · baf6cc0 · baf6cc0
1 parent a4e5a04
commit baf6cc0
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/src/errors.rs b/src/errors.rs
@@ -89,6 +89,12 @@ impl From<crate::channel::TryRecvError> for Error {
     }
 }
 
+impl<T> From<async_channel::SendError<T>> for Error {
+    fn from(e: async_channel::SendError<T>) -> Self {
+        Self::from(format!("{e:?}"))
+    }
+}
+
 impl<T> From<async_std::channel::SendError<T>> for Error {
     fn from(e: async_std::channel::SendError<T>) -> Self {
         Self::from(format!("{e:?}"))
@@ -462,4 +468,11 @@ mod test {
         let r = Error::from(e);
         assert_matches!(r.0, ErrorKind::S3Error(_));
     }
+
+    #[test]
+    fn send_error() {
+        let e = async_channel::SendError(0u8);
+        let error = Error::from(e);
+        assert_eq!(error.to_string(), "SendError(..)".to_string(),);
+    }
 }