]> Repositorios git - scryer-prolog.git/commitdiff
cargo fmt
authorDanil Platonov <[email protected]>
Sat, 30 May 2026 22:56:18 +0000 (15:56 -0700)
committerDanil Platonov <[email protected]>
Sat, 30 May 2026 22:56:18 +0000 (15:56 -0700)
src/machine/system_calls.rs

index becb48f203ca483cb48ad73ef29e5df09ecf0f96..43e81446df06aa4b87c7cf5cd716809bd4f8c3d5 100644 (file)
@@ -4661,23 +4661,31 @@ impl Machine {
             runtime.spawn(async move {
                 match ssl_server {
                     Some((key, cert)) => {
-                        let (_addr, server) = warp::serve(serve).tls().key(key).cert(cert).bind_with_graceful_shutdown(addr, async move {
-                            warp_shutdown_rx.recv().await;
-                        });
+                        let (_addr, server) = warp::serve(serve)
+                            .tls()
+                            .key(key)
+                            .cert(cert)
+                            .bind_with_graceful_shutdown(addr, async move {
+                                warp_shutdown_rx.recv().await;
+                            });
 
                         tokio::task::spawn(server);
                     }
                     None => {
-                        let (_addr, server) = warp::serve(serve).bind_with_graceful_shutdown(addr, async move {
-                            warp_shutdown_rx.recv().await;
-                        });
+                        let (_addr, server) =
+                            warp::serve(serve).bind_with_graceful_shutdown(addr, async move {
+                                warp_shutdown_rx.recv().await;
+                            });
 
                         tokio::task::spawn(server);
                     }
                 }
             });
 
-            let http_listener = HttpListener { incoming: rx, warp_shutdown: warp_shutdown_tx };
+            let http_listener = HttpListener {
+                incoming: rx,
+                warp_shutdown: warp_shutdown_tx,
+            };
             let http_listener: TypedArenaPtr<HttpListener> =
                 arena_alloc!(http_listener, &mut self.machine_st.arena);