Merge pull request #56 from mempool/junderw/use-blocking-spawn

REST API blocking async: Solution A, block_in_place
mempool · Mar 6, 2024 · f85bf8a · f85bf8a
2 parents 94b9222 + 94cfe27
commit f85bf8a
Showing 1 changed file with 12 additions and 10 deletions.
diff --git a/src/rest.rs b/src/rest.rs
@@ -582,16 +582,18 @@ async fn run_server(
                     let uri = req.uri().clone();
                     let body = hyper::body::to_bytes(req.into_body()).await?;
 
-                    let mut resp = handle_request(method, uri, body, &query, &config)
-                        .unwrap_or_else(|err| {
-                            warn!("{:?}", err);
-                            Response::builder()
-                                .status(err.0)
-                                .header("Content-Type", "text/plain")
-                                .header("X-Powered-By", &**VERSION_STRING)
-                                .body(Body::from(err.1))
-                                .unwrap()
-                        });
+                    let mut resp = tokio::task::block_in_place(|| {
+                        handle_request(method, uri, body, &query, &config)
+                    })
+                    .unwrap_or_else(|err| {
+                        warn!("{:?}", err);
+                        Response::builder()
+                            .status(err.0)
+                            .header("Content-Type", "text/plain")
+                            .header("X-Powered-By", &**VERSION_STRING)
+                            .body(Body::from(err.1))
+                            .unwrap()
+                    });
                     if let Some(ref origins) = config.cors {
                         resp.headers_mut()
                             .insert("Access-Control-Allow-Origin", origins.parse().unwrap());