simon/moonpool
1
0
Fork 0
mirror of https://github.com/c-cube/moonpool.git synced 2025-12-10 05:03:58 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

update lwt test

Browse source
This commit is contained in:
Simon Cruanes 2025-09-04 14:46:53 -04:00
parent 122b3a6b06
commit 6c8c06b391
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
test/lwt/echo_server.ml
View file

@ -11,7 +11,7 @@ let str_of_sockaddr = function
| Unix.ADDR_INET (addr, port) ->
spf "%s:%d" (Unix.string_of_inet_addr addr) port
let main ~port ~verbose ~runner:_ () : unit Lwt.t =
let main ~port ~verbose ~runner:_ () : unit =
let@ _sp = Trace.with_span ~__FILE__ ~__LINE__ "main" in
let lwt_fut, _lwt_prom = Lwt.wait () in
@ -54,7 +54,7 @@ let main ~port ~verbose ~runner:_ () : unit Lwt.t =
Lwt_io.establish_server_with_client_address addr handle_client |> await_lwt
in
lwt_fut
M_lwt.await_lwt lwt_fut
let () =
let@ () = Trace_tef.with_setup () in
@ -75,4 +75,4 @@ let () =
let@ runner = M.Ws_pool.with_ ~name:"tpool" ~num_threads:!j () in
(* Lwt_engine.set @@ new Lwt_engine.libev (); *)
Lwt_main.run @@ main ~runner ~port:!port ~verbose:!verbose ()
M_lwt.lwt_main @@ fun _ -> main ~runner ~port:!port ~verbose:!verbose ()