diff options
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/stream.ml | 12 |
1 files changed, 3 insertions, 9 deletions
diff --git a/lib/stream.ml b/lib/stream.ml index e6a46b8..b997a25 100644 --- a/lib/stream.ml +++ b/lib/stream.ml @@ -79,12 +79,6 @@ let negotiate let initiate (domain : string) (auth : Sasl.auth_config) : (Portal.t * features) Lwt.t = let open Portal in let* p = connect domain - in let push = function - | Some n -> p.push (Some n) - | None -> - p.push (Some close); - (* Empty the stream completely, then close the socket. *) - Lwt.async (fun () -> let+ () = Markup_lwt.drain p.stream in p.push None) - in let portal = {p with push} in - let+ features = negotiate domain portal auth - in (portal, features) + in let+ features = negotiate domain p auth + in (p, features) + |