diff options
| author | Clombrong <cromblong@egregore.fun> | 2025-06-26 22:35:53 +0200 |
|---|---|---|
| committer | Clombrong <cromblong@egregore.fun> | 2025-06-27 08:56:42 +0200 |
| commit | 63f009280f29942ec2ea85176240e78becb2326b (patch) | |
| tree | 9b73716ff154ea5b871cc3bdcd0dd3ac86e9f211 /portal/tcp/portal.ml | |
| parent | 41aa93cf6465201447e13e9db0440aaac00cb4e2 (diff) | |
feat(portal): add field in t for underlying socket
Diffstat (limited to 'portal/tcp/portal.ml')
| -rw-r--r-- | portal/tcp/portal.ml | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/portal/tcp/portal.ml b/portal/tcp/portal.ml index 931cf93..8d0c8fc 100644 --- a/portal/tcp/portal.ml +++ b/portal/tcp/portal.ml @@ -7,13 +7,14 @@ type socket = file_descr type t = { stream : (signal, async) stream; push : (signal, sync) stream option -> unit; + _socket : socket; } let xmlns = "http://etherx.jabber.org/streams" exception MalformedStanza of Markup.location * Markup.Error.t -let header ?from domain ({stream; push} : t) = +let header ?from domain ({stream; push; _} : t) = let stanza = let attributes = [(("", "to"), domain); (("", "version"), "1.0"); @@ -102,4 +103,4 @@ let connect (domain : string) : t Lwt.t = in Lwt.async (fun () -> let* _ = lwt_stream xml_stream |> Markup_lwt.write_xml |> iter send in Lwt_unix.close tcp_socket); - {stream; push} + {stream; push; _socket=tcp_socket} |