aboutsummaryrefslogtreecommitdiff
path: root/portal/tcp
diff options
context:
space:
mode:
authorClombrong <cromblong@egregore.fun>2025-06-28 18:31:29 +0200
committerClombrong <cromblong@egregore.fun>2025-06-28 18:47:34 +0200
commit7fb5351f1a92746eb9d35e73f212400963cf2424 (patch)
tree0274b75442ca61fd793a6f48f8f0a4bf03a91ae9 /portal/tcp
parent96b01e8304d30dd86969be9ad88638576af9db83 (diff)
feat(portal_tcp, portal_ws): throw MalformedStanza asynchronously
Diffstat (limited to 'portal/tcp')
-rw-r--r--portal/tcp/portal.ml2
1 files changed, 1 insertions, 1 deletions
diff --git a/portal/tcp/portal.ml b/portal/tcp/portal.ml
index 6b7bff6..cec5212 100644
--- a/portal/tcp/portal.ml
+++ b/portal/tcp/portal.ml
@@ -156,7 +156,7 @@ let socket_to_stream (sock : socket) =
in let push = function
| None -> outbound_push None
| Some signals -> Markup.iter (fun f -> outbound_push (Some f)) signals
- and report _ err = raise (MalformedStanza err) in
+ and report _ err = Lwt.fail (MalformedStanza err) in
let open Markup_lwt in
let stream = raw_stream
|> lwt_stream