name http worker threads

src/debug_server.rs

@@ -1,3 +1,5 @@
+use futures::Future;
+use hyper::rt::Executor;
 use hyper::service::{make_service_fn, service_fn};
 use hyper::{Body, Response, Server};
 use std::convert::Infallible;
@@ -6,21 +8,32 @@ use std::sync::Arc;
 use tokio::sync::Mutex;
 
 use crate::ports::PortHandler;
+use crate::spawn;
+
+#[derive(Clone)]
+struct NamedExecutor;
+impl<T: Send + 'static, Fut: Future<Output = T> + Send + 'static> Executor<Fut> for NamedExecutor {
+    fn execute(&self, fut: Fut) {
+        spawn("http worker", fut);
+    }
+}
 
 pub async fn debug_server(addr: SocketAddr, port_handler: Arc<Mutex<PortHandler>>) {
-    let server = Server::bind(&addr).serve(make_service_fn(move |_conn| {
+    let server = Server::bind(&addr)
-        let port_handler = port_handler.clone();
+        .executor(NamedExecutor)
-        async move {
+        .serve(make_service_fn(move |_conn| {
-            Ok::<_, Infallible>(service_fn(move |_req| {
+            let port_handler = port_handler.clone();
-                let port_handler = port_handler.clone();
+            async move {
-                async move {
+                Ok::<_, Infallible>(service_fn(move |_req| {
-                    Ok::<_, Infallible>(Response::new(Body::from(
+                    let port_handler = port_handler.clone();
-                        port_handler.lock().await.status_string(),
+                    async move {
-                    )))
+                        Ok::<_, Infallible>(Response::new(Body::from(
-                }
+                            port_handler.lock().await.status_string(),
-            }))
+                        )))
-        }
+                    }
-    }));
+                }))
+            }
+        }));
 
     // Run this server for... forever!
     if let Err(e) = server.await {