Fix clippy warnings

surban · Jan 23, 2025 · 50ede6c · 50ede6c
1 parent 7a75952
commit 50ede6c
Showing 1 changed file with 13 additions and 12 deletions.
diff --git a/aggligator-transport-websocket/src/lib.rs b/aggligator-transport-websocket/src/lib.rs
@@ -275,16 +275,16 @@ impl ConnectingTransport for WebSocketConnector {
         let (ws_tx, ws_rx) = web_socket.split();
         let ws_tx = Box::pin(
             ws_tx
-                .with(|data: Bytes| async move {
-                    Ok::<_, tungstenite::Error>(tungstenite::Message::Binary(data.into()))
-                })
+                .with(
+                    |data: Bytes| async move { Ok::<_, tungstenite::Error>(tungstenite::Message::Binary(data)) },
+                )
                 .sink_map_err(|err| Error::new(ErrorKind::Other, err)),
         );
         let ws_rx = Box::pin(
             ws_rx
                 .try_filter_map(|msg: tungstenite::Message| async move {
                     if let tungstenite::Message::Binary(data) = msg {
-                        Ok(Some(data.into()))
+                        Ok(Some(data))
                     } else {
                         Ok(None)
                     }
@@ -504,18 +504,19 @@ impl AcceptingTransport for WebSocketAcceptor {
 
             // Adapt WebSocket IO.
             let (ws_tx, ws_rx) = web_socket.split();
-            let ws_tx = Box::pin(
-                ws_tx
-                    .with(|data: Bytes| async move {
-                        Ok::<_, axum::Error>(axum::extract::ws::Message::Binary(data.into()))
-                    })
-                    .sink_map_err(|err| Error::new(ErrorKind::Other, err)),
-            );
+            let ws_tx =
+                Box::pin(
+                    ws_tx
+                        .with(|data: Bytes| async move {
+                            Ok::<_, axum::Error>(axum::extract::ws::Message::Binary(data))
+                        })
+                        .sink_map_err(|err| Error::new(ErrorKind::Other, err)),
+                );
             let ws_rx = Box::pin(
                 ws_rx
                     .try_filter_map(|msg: axum::extract::ws::Message| async move {
                         if let axum::extract::ws::Message::Binary(data) = msg {
-                            Ok(Some(data.into()))
+                            Ok(Some(data))
                         } else {
                             Ok(None)
                         }