Fix async-std and re-enable Ci for async-std builds

.github/workflows/ci.yaml

@@ -17,18 +17,27 @@ jobs:
           - name: Run the default tests
             package: ractor
             # flags: 
-          - name: Test ractor without async-trait
+          - name: Test ractor with async-trait
             package: ractor
-            flags: --no-default-features -F tokio_runtime,message_span_propogation
+            flags: -F async-trait
           - name: Test ractor without span propogation
             package: ractor
-            flags: --no-default-features -F tokio_runtime,async-trait
+            flags: --no-default-features -F tokio_runtime
           - name: Test ractor with the `cluster` feature
             package: ractor
             flags: -F cluster
           - name: Test ractor with the `blanket_serde` feature
             package: ractor
             flags: -F blanket_serde
+          - name: Test ractor with async-std runtime
+            package: ractor
+            flags: --no-default-features -F async-std,message_span_propogation
+          - name: Test ractor with async-std runtime but no span propagation
+            package: ractor
+            flags: --no-default-features -F async-std
+          - name: Test ractor with async-std runtime and async-trait
+            package: ractor
+            flags: --no-default-features -F async-std,async-trait
           - name: Test ractor_cluster with native async traits
             package: ractor_cluster
             # flags: 

ractor/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ractor"
-version = "0.14.6"
+version = "0.14.7"
 authors = ["Sean Lawlor", "Evan Au", "Dillon George"]
 description = "A actor framework for Rust"
 documentation = "https://docs.rs/ractor"

ractor/src/actor/supervision.rs

@@ -134,10 +134,20 @@ impl SupervisionTree {
         }
         // drain the tasks
         while let Some(res) = js.join_next().await {
-            match res {
-                Err(err) if err.is_panic() => std::panic::resume_unwind(err.into_panic()),
-                Err(err) => panic!("{err}"),
-                _ => {}
+            #[cfg(feature = "async-std")]
+            {
+                match res {
+                    Err(_) => panic!("JoinSet join error"),
+                    _ => {}
+                }
+            }
+            #[cfg(not(feature = "async-std"))]
+            {
+                match res {
+                    Err(err) if err.is_panic() => std::panic::resume_unwind(err.into_panic()),
+                    Err(err) => panic!("{err}"),
+                    _ => {}
+                }
             }
         }
     }
@@ -155,10 +165,20 @@ impl SupervisionTree {
         }
         // drain the tasks
         while let Some(res) = js.join_next().await {
-            match res {
-                Err(err) if err.is_panic() => std::panic::resume_unwind(err.into_panic()),
-                Err(err) => panic!("{err}"),
-                _ => {}
+            #[cfg(feature = "async-std")]
+            {
+                match res {
+                    Err(_) => panic!("JoinSet join error"),
+                    _ => {}
+                }
+            }
+            #[cfg(not(feature = "async-std"))]
+            {
+                match res {
+                    Err(err) if err.is_panic() => std::panic::resume_unwind(err.into_panic()),
+                    Err(err) => panic!("{err}"),
+                    _ => {}
+                }
             }
         }
     }

ractor/src/concurrency/async_std_primitives.rs

@@ -9,6 +9,7 @@
 //! such as channels (see: https://github.com/tokio-rs/tokio/issues/4232#issuecomment-968329443).
 
 use std::{
+    fmt::Debug,
     future::Future,
     pin::Pin,
     sync::{
@@ -28,6 +29,16 @@ pub struct JoinHandle<T> {
     handle: Option<async_std::task::JoinHandle<T>>,
     is_done: Arc<AtomicBool>,
 }
+
+impl<T> Debug for JoinHandle<T> {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        f.debug_struct("JoinHandle")
+            .field("name", &self.is_done.load(Ordering::Relaxed))
+            .field("handle", &self.handle.is_some())
+            .finish()
+    }
+}
+
 impl<T> JoinHandle<T> {
     /// Determine if the handle is currently finished
     pub fn is_finished(&self) -> bool {
@@ -74,6 +85,7 @@ pub type Instant = std::time::Instant;
 /// An asynchronous interval calculation which waits until
 /// a checkpoint time to tick. This is a replication of the
 /// basic functionality from `tokio`'s `Interval`.
+#[derive(Debug, Clone)]
 pub struct Interval {
     dur: Duration,
     next_tick: Instant,
@@ -110,6 +122,14 @@ pub struct JoinSet<T> {
     set: FuturesUnordered<BoxFuture<'static, T>>,
 }
 
+impl<T> Debug for JoinSet<T> {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        f.debug_struct("JoinSet")
+            .field("size", &self.set.len())
+            .finish()
+    }
+}
+
 impl<T> JoinSet<T> {
     /// Creates a new [JoinSet]
     pub fn new() -> JoinSet<T> {

ractor_cluster/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ractor_cluster"
-version = "0.14.6"
+version = "0.14.7"
 authors = ["Sean Lawlor <slawlor>"]
 description = "Distributed cluster environment of Ractor actors"
 documentation = "https://docs.rs/ractor"

ractor_cluster_derive/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ractor_cluster_derive"
-version = "0.14.6"
+version = "0.14.7"
 authors = ["Sean Lawlor <slawlor>"]
 description = "Derives for ractor_cluster"
 license = "MIT"