clippy fix

ideal-world · Jun 19, 2024 · 932a1b0 · 932a1b0
1 parent 528a11d
commit 932a1b0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/examples/websocket/src/processor.rs b/examples/websocket/src/processor.rs
@@ -1,4 +1,5 @@
 use std::collections::HashMap;
+use std::sync::Arc;
 
 use serde::{Deserialize, Serialize};
 use tardis::basic::result::TardisResult;
@@ -127,7 +128,7 @@ impl Page {
     }
 
     #[oai(path = "/ws/broadcast/:name", method = "get")]
-    async fn ws_broadcast(&self, name: Path<String>, websocket: WebSocket, sender: Data<&Sender<TardisWebsocketMgrMessage>>) -> BoxWebSocketUpgraded {
+    async fn ws_broadcast(&self, name: Path<String>, websocket: WebSocket, sender: Data<&Sender<Arc<TardisWebsocketMgrMessage>>>) -> BoxWebSocketUpgraded {
         pub struct Hooks {
             ext: HashMap<String, String>,
         }

diff --git a/tardis/src/web/ws_processor/cluster_protocol.rs b/tardis/src/web/ws_processor/cluster_protocol.rs
@@ -10,7 +10,7 @@ impl WsBroadcastSender for ClusterBroadcastChannel<TardisWebsocketMgrMessage> {
     }
 
     async fn send(&self, msg: TardisWebsocketMgrMessage) -> TardisResult<()> {
-        self.send(msg.into()).await
+        self.send(msg).await
     }
 }
 
@@ -20,6 +20,6 @@ impl WsBroadcastSender for Arc<ClusterBroadcastChannel<TardisWebsocketMgrMessage
     }
 
     async fn send(&self, msg: TardisWebsocketMgrMessage) -> TardisResult<()> {
-        ClusterBroadcastChannel::send(self, msg.into()).await
+        ClusterBroadcastChannel::send(self, msg).await
     }
 }