From 4da55bcedf111f3d0fbaf1e1b8eb3dfa51488348 Mon Sep 17 00:00:00 2001 From: Clombrong Date: Tue, 17 Jun 2025 20:54:24 +0200 Subject: feat(stream): wrap Lwt_stream.get to support ClosedStream exception --- test/js/websockets_hello.ml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'test') diff --git a/test/js/websockets_hello.ml b/test/js/websockets_hello.ml index 877e543..0781e4a 100644 --- a/test/js/websockets_hello.ml +++ b/test/js/websockets_hello.ml @@ -18,7 +18,7 @@ let rec run t = else () let main (stream, push) config = - let* _stream = Lwt_stream.get stream + let* _stream = Stream.get stream in let+ _auth = Sasl.authenticate (stream, push) config in match _auth with | Error (NotAuthorized, Some (_, text)) -> print_endline ("Not authorized: " ^ text) -- cgit v1.2.3