diff options
| author | Clombrong <cromblong@egregore.fun> | 2025-06-28 00:42:03 +0200 |
|---|---|---|
| committer | Clombrong <cromblong@egregore.fun> | 2025-06-28 07:38:36 +0200 |
| commit | bcc6e7578ff63d4e0f37fbf3d7312e0082bdc98e (patch) | |
| tree | eb2dc5be28d2a16adeed2b0f4a0317a0467c2b39 /portal/tcp | |
| parent | e985ff60318dd5bad2928bf703f639d64f3df932 (diff) | |
style(portal_tcp): make push function less ugly
Diffstat (limited to 'portal/tcp')
| -rw-r--r-- | portal/tcp/portal.ml | 8 |
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 |