blob: 5da4aea703b426b60f7f27a97b7b884debee8eb8 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
|
open Lwt.Syntax
let start domain : Portal.t Lwt.t =
let* stream, _push = Portal.connect domain
in let push = function
| None -> _push (Some Portal.stanza_close);
_push None;
| anything -> _push anything
in Some (Portal.stanza_open domain) |> push;
(* TODO: check this is a good stanza *)
let+ _ = Lwt_stream.get stream
in stream, push
|
