lint: remove some unused async

Author: barafael

examples/chat.rs

@@ -138,7 +138,7 @@ impl Shared {
 
     /// Send a `LineCodec` encoded message to every peer, except
     /// for the sender.
-    async fn broadcast(&mut self, sender: SocketAddr, message: &str) {
+    fn broadcast(&mut self, sender: SocketAddr, message: &str) {
         for peer in &mut self.peers {
             if *peer.0 != sender {
                 let _ = peer.1.send(message.into());
@@ -192,7 +192,7 @@ async fn process(
         let mut state = state.lock().await;
         let msg = format!("{username} has joined the chat");
         tracing::info!("{}", msg);
-        state.broadcast(addr, &msg).await;
+        state.broadcast(addr, &msg);
     }
 
     // Process incoming messages until our stream is exhausted by a disconnect.
@@ -209,7 +209,7 @@ async fn process(
                     let mut state = state.lock().await;
                     let msg = format!("{username}: {msg}");
 
-                    state.broadcast(addr, &msg).await;
+                    state.broadcast(addr, &msg);
                 }
                 // An error occurred.
                 Some(Err(e)) => {
@@ -233,7 +233,7 @@ async fn process(
 
         let msg = format!("{username} has left the chat");
         tracing::info!("{}", msg);
-        state.broadcast(addr, &msg).await;
+        state.broadcast(addr, &msg);
     }
 
     Ok(())

examples/tinyhttp.rs

@@ -49,7 +49,7 @@ async fn process(stream: TcpStream) -> Result<(), Box<dyn Error>> {
     while let Some(request) = transport.next().await {
         match request {
             Ok(request) => {
-                let response = respond(request).await?;
+                let response = respond(request)?;
                 transport.send(response).await?;
             }
             Err(e) => return Err(e.into()),
@@ -59,7 +59,7 @@ async fn process(stream: TcpStream) -> Result<(), Box<dyn Error>> {
     Ok(())
 }
 
-async fn respond(req: Request<()>) -> Result<Response<String>, Box<dyn Error>> {
+fn respond(req: Request<()>) -> Result<Response<String>, Box<dyn Error>> {
     let mut response = Response::builder();
     let body = match req.uri().path() {
         "/plaintext" => {

tokio/tests/sync_mpsc_weak.rs

@@ -354,7 +354,7 @@ async fn actor_weak_unbounded_sender() {
             }
         }
 
-        async fn send_message_to_self(&mut self) {
+        fn send_message_to_self(&mut self) {
             let msg = ActorMessage::SelfMessage {};
 
             let sender = self.sender.clone();
@@ -372,7 +372,7 @@ async fn actor_weak_unbounded_sender() {
                 self.handle_message(msg);
 
                 if i == 0 {
-                    self.send_message_to_self().await;
+                    self.send_message_to_self();
                 }
 
                 i += 1;