From 1fa0e770fe4d6108fe85ca7b49fd0e0b1e545215 Mon Sep 17 00:00:00 2001
From: Clombrong <cromblong@egregore.fun>
Date: Sun, 29 Jun 2025 05:37:20 +0200
Subject: feat(portal_tcp): send closing element when pushing None

---
 lib/stream.ml | 12 +++---------
 1 file changed, 3 insertions(+), 9 deletions(-)

(limited to 'lib')

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)
+
-- 
cgit v1.2.3