Deal with some linter warnings

Author: Qard

src/asgi/mod.rs

@@ -50,35 +50,30 @@ pub async fn execute_asgi_http_scope(
     let mut body = Vec::new();
     let mut response_started = false;
 
-    loop {
-      if let Some(msg) = tx.recv().await {
-        match msg {
-          HttpSendMessage::HttpResponseStart {
-            status: s,
-            headers: h,
-            trailers: _
-          } => {
-            status = s;
-            headers = h;
-            response_started = true;
-          }
-          HttpSendMessage::HttpResponseBody {
-            body: b,
-            more_body
-          } => {
-            if response_started {
-              body.extend_from_slice(&b);
-              if !more_body {
-                // Response is complete
-                let _ = response_tx.send((status, headers, body));
-                break;
-              }
+    while let Some(msg) = tx.recv().await {
+      match msg {
+        HttpSendMessage::HttpResponseStart {
+          status: s,
+          headers: h,
+          trailers: _
+        } => {
+          status = s;
+          headers = h;
+          response_started = true;
+        }
+        HttpSendMessage::HttpResponseBody {
+          body: b,
+          more_body
+        } => {
+          if response_started {
+            body.extend_from_slice(&b);
+            if !more_body {
+              // Response is complete
+              let _ = response_tx.send((status, headers, body));
+              break;
             }
           }
         }
-      } else {
-        // Channel closed
-        break;
       }
     }
   });
@@ -105,8 +100,8 @@ pub async fn execute_asgi_http_scope(
       let coroutine = match py_func.call1(py, (scope_py, rx_receiver, tx_sender)) {
         Ok(coro) => coro,
         Err(e) => {
-          eprintln!("Failed to call ASGI app: {}", e);
-          let _ = python_done_tx.send(Err(format!("Failed to call ASGI app: {}", e)));
+          eprintln!("Failed to call ASGI app: {e}");
+          let _ = python_done_tx.send(Err(format!("Failed to call ASGI app: {e}")));
           return;
         }
       };
@@ -115,8 +110,8 @@ pub async fn execute_asgi_http_scope(
       let asyncio = match py.import("asyncio") {
         Ok(module) => module,
         Err(e) => {
-          eprintln!("Failed to import asyncio: {}", e);
-          let _ = python_done_tx.send(Err(format!("Failed to import asyncio: {}", e)));
+          eprintln!("Failed to import asyncio: {e}");
+          let _ = python_done_tx.send(Err(format!("Failed to import asyncio: {e}")));
           return;
         }
       };
@@ -125,16 +120,16 @@ pub async fn execute_asgi_http_scope(
       let loop_ = match asyncio.call_method0("new_event_loop") {
         Ok(loop_) => loop_,
         Err(e) => {
-          eprintln!("Failed to create event loop: {}", e);
-          let _ = python_done_tx.send(Err(format!("Failed to create event loop: {}", e)));
+          eprintln!("Failed to create event loop: {e}");
+          let _ = python_done_tx.send(Err(format!("Failed to create event loop: {e}")));
           return;
         }
       };
 
       // Set it as the current event loop
       if let Err(e) = asyncio.call_method1("set_event_loop", (&loop_,)) {
-        eprintln!("Failed to set event loop: {}", e);
-        let _ = python_done_tx.send(Err(format!("Failed to set event loop: {}", e)));
+        eprintln!("Failed to set event loop: {e}");
+        let _ = python_done_tx.send(Err(format!("Failed to set event loop: {e}")));
         return;
       }
 
@@ -149,7 +144,7 @@ pub async fn execute_asgi_http_scope(
       std::thread::sleep(std::time::Duration::from_millis(10));
 
       let _ = python_done_tx.send(result.map(|_| ()).map_err(|e| {
-        format!("Failed to run ASGI coroutine: {}", e)
+        format!("Failed to run ASGI coroutine: {e}")
       }));
     });
   });
@@ -193,5 +188,5 @@ pub async fn execute_asgi_http_scope(
 
   builder
     .body(BytesMut::from(&body[..]))
-    .map_err(|e| pyo3::exceptions::PyRuntimeError::new_err(format!("Failed to build response: {}", e)))
+    .map_err(|e| pyo3::exceptions::PyRuntimeError::new_err(format!("Failed to build response: {e}")))
 }