chore: update kanal version (#869)

Closes #868

Author: andrewgazelka

Cargo.lock

@@ -78,7 +78,7 @@ hex = '0.4.3'
 humantime = '2.1.0'
 hyperion-proxy = { path = "crates/hyperion-proxy" }
 itertools = "0.14.0"
-kanal = '0.1.0-pre8'
+kanal = '0.1.0'
 libc = '0.2.170'
 libdeflater = '1.23.1'
 memmap2 = '0.9.5'

Cargo.toml

@@ -121,7 +121,7 @@ impl PlayerHandle {
 
     pub fn shutdown(&self) {
         let _ = self.writer.try_send(OrderedBytes::SHUTDOWN);
-        self.writer.close();
+        self.writer.close().unwrap();
     }
 
     pub fn enable_receive_broadcasts(&self) {
@@ -143,7 +143,7 @@ impl PlayerHandle {
                 bail!("failed to send packet to player, channel is full: {is_full}");
             }
             Err(e) => {
-                self.writer.close();
+                self.writer.close().unwrap();
                 bail!("failed to send packet to player: {e}");
             }
         }

crates/hyperion-proxy/src/data.rs

@@ -7,7 +7,7 @@ use flecs_ecs::{core::World, macros::Component};
 use kanal::{Receiver, Sender};
 
 /// Type alias for world callback functions
-pub type WorldCallback = Box<dyn FnOnce(&World)>;
+pub type WorldCallback = Box<dyn FnOnce(&World) + Send>;
 
 /// Wrapper around [`tokio::runtime::Runtime`]
 #[derive(Component, Deref, DerefMut, Clone)]
@@ -24,11 +24,13 @@ pub struct Tasks {
 }
 
 impl AsyncRuntime {
-    pub fn schedule<T: 'static>(
+    pub fn schedule<T>(
         &self,
         future: impl Future<Output = T> + Send + 'static,
         handler: fn(T, &World),
-    ) {
+    ) where
+        T: Send + 'static,
+    {
         let sender = self.callback_sender.clone();
 
         self.spawn(async move {

crates/hyperion/src/common/runtime.rs

@@ -10,7 +10,7 @@ use flecs_ecs::core::World;
 use crate::NUM_THREADS;
 
 /// Thread-local in flecs environment
-#[derive(Debug, Default)]
+#[derive(Debug, Default, Copy, Clone)]
 pub struct ThreadLocal<T> {
     locals: [T; NUM_THREADS],
 }