diff options
Diffstat (limited to 'test/js/websockets_hello.ml')
| -rw-r--r-- | test/js/websockets_hello.ml | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/test/js/websockets_hello.ml b/test/js/websockets_hello.ml index 5705dc9..6bc863b 100644 --- a/test/js/websockets_hello.ml +++ b/test/js/websockets_hello.ml @@ -1,5 +1,6 @@ open Lwt.Syntax open Js_of_ocaml +open Flesh (* https://stackoverflow.com/questions/34929382/what-are-the-differences-between-lwt-async-and-lwt-main-run-on-ocaml-node-js *) let rec run t = @@ -18,11 +19,8 @@ let rec run t = let () = run @@ let domain = "egregore.fun" in - let* stream, push = - Portal.connect domain in - push (Some (Portal.stanza_open domain)); - push (Some Portal.stanza_close); - Lwt_stream.iter - (fun stanza -> - print_endline (">>> " ^ stanza)) - stream + let* stream, push = Stream.start domain + in push (Some (Portal.stanza_open domain)); + let+ opens = Lwt_stream.get stream + in print_endline (Option.get opens); + push (Some (Portal.stanza_close)) |