Improve async channels error handling and replace unbounded channels with bounded channels

Remove all unbounded channels to prevent unbounded memory usage and
potential crashes.

Use `FuturesUnordered` for sending to multiple channels simultaneously.
This prevents the sending loop from blocking if one channel is blocked,
and helps handle errors properly.

1 files changed, 5 insertions, 0 deletions

diff --git a/core/src/async_runtime/executor.rs b/core/src/async_runtime/executor.rs
index 9335f12..88f6370 100644
--- a/core/src/async_runtime/executor.rs
+++ b/core/src/async_runtime/executor.rs
@@ -25,6 +25,11 @@ impl Executor {
     ) -> Task<T> {
         self.inner.spawn(future).into()
     }
+
+    #[cfg(feature = "tokio")]
+    pub fn handle(&self) -> &tokio::runtime::Handle {
+        return self.inner.handle();
+    }
 }
 
 static GLOBAL_EXECUTOR: OnceCell<Executor> = OnceCell::new();