feat: Channel util improvements (#22)

* feat: Channel util improvements

* clean up

* clean up

Author: marc2332

examples/channel/src/main.rs

@@ -12,14 +12,14 @@ fn main() {
 fn app(cx: Scope) -> Element {
     let channel = use_channel::<String>(cx, 5);
 
-    use_listen_channel(cx, &channel, move |message| async move {
+    use_listen_channel(cx, &channel, |message| async {
         match message {
             Ok(value) => log::info!("Incoming message: {value}"),
             Err(err) => log::info!("Error: {err:?}"),
         }
     });
 
-    let send = move |_: MouseEvent| {
+    let send = |_: MouseEvent| {
         to_owned![channel];
         async move {
             channel.send("Hello").await.ok();

std/src/i18n/mod.rs

@@ -2,6 +2,5 @@ mod tanslate;
 mod use_i18n;
 mod use_init_i18n;
 
-pub use self::tanslate::*;
 pub use self::use_i18n::*;
 pub use self::use_init_i18n::*;

std/src/utils/channel/use_channel.rs

@@ -38,17 +38,14 @@ impl<MessageType: Clone> UseChannel<MessageType> {
 pub fn use_channel<MessageType: Clone + 'static>(
     cx: &ScopeState,
     size: usize,
-) -> UseChannel<MessageType> {
-    let id = cx.use_hook(Uuid::new_v4);
-    let (sender, inactive_receiver) = cx.use_hook(|| {
+) -> &UseChannel<MessageType> {
+    cx.use_hook(|| {
+        let id = Uuid::new_v4();
         let (sender, receiver) = broadcast::<MessageType>(size);
-
-        (sender, receiver.deactivate())
-    });
-
-    UseChannel {
-        id: *id,
-        sender: sender.clone(),
-        inactive_receiver: inactive_receiver.clone(),
-    }
+        UseChannel {
+            id,
+            sender,
+            inactive_receiver: receiver.deactivate(),
+        }
+    })
 }

std/src/utils/channel/use_listen_channel.rs

@@ -1,7 +1,7 @@
 use std::future::Future;
 
 use async_broadcast::RecvError;
-use dioxus::prelude::{to_owned, use_effect, ScopeState};
+use dioxus::prelude::{use_effect, ScopeState};
 
 use super::UseChannel;
 
@@ -15,19 +15,15 @@ pub fn use_listen_channel<MessageType: Clone + 'static, Handler>(
 ) where
     Handler: Future<Output = ()> + 'static,
 {
-    use_effect(cx, (channel,), move |(channel,)| {
-        to_owned![channel];
-        async move {
-            let action = Box::new(action);
-            let mut receiver = channel.receiver();
+    use_effect(cx, (channel,), move |(mut channel,)| async move {
+        let mut receiver = channel.receiver();
 
-            loop {
-                let message = receiver.recv().await;
-                let message_err = message.clone().err();
-                action(message).await;
-                if message_err == Some(UseListenChannelError::Closed) {
-                    break;
-                }
+        loop {
+            let message = receiver.recv().await;
+            let message_err = message.clone().err();
+            action(message).await;
+            if message_err == Some(UseListenChannelError::Closed) {
+                break;
             }
         }
     });