diff --git a/src/lwt/base.ml b/src/lwt/base.ml index 02e73b5a..40f8fb64 100644 --- a/src/lwt/base.ml +++ b/src/lwt/base.ml @@ -143,7 +143,7 @@ let main_with_runner ~runner (f : unit -> 'a) : 'a = let lwt_fut, lwt_prom = Lwt.wait () in let _fiber = - Fiber.spawn_top ~name:"Moonpool_lwt.main" ~on:runner (fun () -> + Fiber.spawn_top ~on:runner (fun () -> try let x = f () in Perform_action_in_lwt.schedule (Action.Wakeup (lwt_prom, x)) diff --git a/src/lwt/moonpool_lwt.ml b/src/lwt/moonpool_lwt.ml index c89cebe2..8dbc0aee 100644 --- a/src/lwt/moonpool_lwt.ml +++ b/src/lwt/moonpool_lwt.ml @@ -15,17 +15,13 @@ module TCP_server = struct let oc = IO_out.of_unix_fd @@ Lwt_unix.unix_file_descr client_sock in let fut = - M.Fut.spawn ~name:"tcp.server.handler" ~on:runner (fun () -> - handler client_addr ic oc) + M.Fut.spawn ~on:runner (fun () -> handler client_addr ic oc) in let lwt_fut = lwt_of_fut fut in lwt_fut) in - Printf.printf "awaiting server\n%!"; - let s = await_lwt server in - Printf.printf "got server\n%!"; - s + await_lwt server let shutdown self = await_lwt @@ Lwt_io.shutdown_server self end