From 06ece6a8c30541b7b2b6bcbb370fdffc9f1fcb79 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?H=C3=A9ctor=20Ram=C3=B3n=20Jim=C3=A9nez?= Date: Tue, 11 Feb 2025 01:32:51 +0100 Subject: [PATCH] Remove unneded `let _ =` in `websocket` example --- examples/websocket/src/echo.rs | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) diff --git a/examples/websocket/src/echo.rs b/examples/websocket/src/echo.rs index 6fa4c54a0f..149a260ce7 100644 --- a/examples/websocket/src/echo.rs +++ b/examples/websocket/src/echo.rs @@ -22,9 +22,7 @@ pub fn connect() -> impl Sipper { Ok((websocket, _)) => { let (sender, receiver) = mpsc::channel(100); - let _ = output - .send(Event::Connected(Connection(sender))) - .await; + output.send(Event::Connected(Connection(sender))).await; (websocket.fuse(), receiver) } @@ -32,8 +30,7 @@ pub fn connect() -> impl Sipper { tokio::time::sleep(tokio::time::Duration::from_secs(1)) .await; - let _ = output.send(Event::Disconnected).await; - + output.send(Event::Disconnected).await; continue; } }; @@ -43,21 +40,20 @@ pub fn connect() -> impl Sipper { received = websocket.select_next_some() => { match received { Ok(tungstenite::Message::Text(message)) => { - let _ = output.send(Event::MessageReceived(Message::User(message))).await; + output.send(Event::MessageReceived(Message::User(message))).await; } Err(_) => { - let _ = output.send(Event::Disconnected).await; + output.send(Event::Disconnected).await; break; } - Ok(_) => continue, + Ok(_) => {}, } } - message = input.select_next_some() => { let result = websocket.send(tungstenite::Message::Text(message.to_string())).await; if result.is_err() { - let _ = output.send(Event::Disconnected).await; + output.send(Event::Disconnected).await; } } }