aboutsummaryrefslogtreecommitdiff
path: root/portal/tcp/portal.ml
diff options
context:
space:
mode:
authorClombrong <cromblong@egregore.fun>2025-06-28 00:42:03 +0200
committerClombrong <cromblong@egregore.fun>2025-06-28 07:38:36 +0200
commitbcc6e7578ff63d4e0f37fbf3d7312e0082bdc98e (patch)
treeeb2dc5be28d2a16adeed2b0f4a0317a0467c2b39 /portal/tcp/portal.ml
parente985ff60318dd5bad2928bf703f639d64f3df932 (diff)
style(portal_tcp): make push function less ugly
Diffstat (limited to 'portal/tcp/portal.ml')
-rw-r--r--portal/tcp/portal.ml8
1 files changed, 3 insertions, 5 deletions
diff --git a/portal/tcp/portal.ml b/portal/tcp/portal.ml
index 72074a5..f3c47e4 100644
--- a/portal/tcp/portal.ml
+++ b/portal/tcp/portal.ml
@@ -85,11 +85,9 @@ let socket_to_stream (sock : socket) =
(* This is gross, but it doesn't matter because TCP does buffering. *)
let+ _ = Lwt_unix.write_string sock (Char.escaped c) 0 1 in ()
and xml_stream, xml_push = Lwt_stream.create ()
- in let push msg =
- let none () = xml_push None
- and some fragments () =
- Markup.iter (fun f -> xml_push (Some f)) fragments
- in Option.fold ~none ~some msg ()
+ in let push = function
+ | None -> xml_push None
+ | Some signals -> Markup.iter (fun f -> xml_push (Some f)) signals
and report loc err = raise (MalformedStanza (loc, err)) in
let open Markup_lwt in
let stream = raw_stream