Skip to content

Commit 4286eed

Browse files
committed
update lwt test
1 parent 2396e56 commit 4286eed

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

test/lwt/echo_server.ml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ let str_of_sockaddr = function
1111
| Unix.ADDR_INET (addr, port) ->
1212
spf "%s:%d" (Unix.string_of_inet_addr addr) port
1313

14-
let main ~port ~verbose ~runner:_ () : unit Lwt.t =
14+
let main ~port ~verbose ~runner:_ () : unit =
1515
let@ _sp = Trace.with_span ~__FILE__ ~__LINE__ "main" in
1616

1717
let lwt_fut, _lwt_prom = Lwt.wait () in
@@ -54,7 +54,7 @@ let main ~port ~verbose ~runner:_ () : unit Lwt.t =
5454
Lwt_io.establish_server_with_client_address addr handle_client |> await_lwt
5555
in
5656

57-
lwt_fut
57+
M_lwt.await_lwt lwt_fut
5858

5959
let () =
6060
let@ () = Trace_tef.with_setup () in
@@ -75,4 +75,4 @@ let () =
7575

7676
let@ runner = M.Ws_pool.with_ ~name:"tpool" ~num_threads:!j () in
7777
(* Lwt_engine.set @@ new Lwt_engine.libev (); *)
78-
Lwt_main.run @@ main ~runner ~port:!port ~verbose:!verbose ()
78+
M_lwt.lwt_main @@ fun _ -> main ~runner ~port:!port ~verbose:!verbose ()

0 commit comments

Comments
 (0)