diff options
| author | Clombrong <cromblong@egregore.fun> | 2025-06-28 01:27:44 +0200 |
|---|---|---|
| committer | Clombrong <cromblong@egregore.fun> | 2025-06-28 07:39:19 +0200 |
| commit | 747fda99b8056832a133c39e4c898107260a3c83 (patch) | |
| tree | 713f0fbd36df9e6f525076b9f8ea03dfdb98144c /portal/tcp | |
| parent | bab95e7234168d3e41f5a2dc4f213f6897919287 (diff) | |
style(portal_tcp): rename xml_ to outbound_
Diffstat (limited to 'portal/tcp')
| -rw-r--r-- | portal/tcp/portal.ml | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/portal/tcp/portal.ml b/portal/tcp/portal.ml index 35930e4..c558888 100644 --- a/portal/tcp/portal.ml +++ b/portal/tcp/portal.ml @@ -104,10 +104,10 @@ let socket_to_stream (sock : socket) = if Buffer.length buffer >= 1024 || c = '>' then flush_buffer () else Lwt.return_unit - and xml_stream, xml_push = Lwt_stream.create () + and outbound_stream, outbound_push = Lwt_stream.create () in let push = function - | None -> xml_push None - | Some signals -> Markup.iter (fun f -> xml_push (Some f)) signals + | None -> outbound_push None + | Some signals -> Markup.iter (fun f -> outbound_push (Some f)) signals and report loc err = raise (MalformedStanza (loc, err)) in let open Markup_lwt in let stream = raw_stream @@ -116,7 +116,7 @@ let socket_to_stream (sock : socket) = |> parse_xml ~report |> signals in Lwt.async (fun () -> - let* _ = lwt_stream xml_stream |> Markup_lwt.write_xml |> iter chomp + let* _ = lwt_stream outbound_stream |> Markup_lwt.write_xml |> iter chomp in let* _ = flush_buffer () in Lwt_unix.close sock); (stream, push) |