From 979290eff020f00ab207013ebb390b3cedb86840 Mon Sep 17 00:00:00 2001 From: Clombrong Date: Sat, 28 Jun 2025 01:08:31 +0200 Subject: chore(portal_tcp): socket_to_stream: rename buffer into recv_bytes --- portal/tcp/portal.ml | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'portal') diff --git a/portal/tcp/portal.ml b/portal/tcp/portal.ml index 28ef8a6..89adb2d 100644 --- a/portal/tcp/portal.ml +++ b/portal/tcp/portal.ml @@ -74,10 +74,10 @@ let tcp_socket (domain : string) : Lwt_unix.file_descr Lwt.t = Markup signals. *) let socket_to_stream (sock : socket) = let raw_stream = - let buffer = Bytes.create 4096 in + let recv_bytes = Bytes.create 4096 in Lwt_stream.from (fun () -> let* len = - try%lwt Lwt_unix.read sock buffer 0 4096 + try%lwt Lwt_unix.read sock recv_bytes 0 4096 with | Unix.Unix_error (Unix.ECONNRESET, _, _) | Unix.Unix_error (Unix.EPIPE, _, _) @@ -85,7 +85,7 @@ let socket_to_stream (sock : socket) = | exn -> Lwt.fail exn in match len with | 0 -> Lwt.return_none - | len -> Lwt.return_some (Bytes.sub_string buffer 0 len)) + | len -> Lwt.return_some (Bytes.sub_string recv_bytes 0 len)) and send_char c = (* This is gross, but it doesn't matter because TCP does buffering. *) let+ _ = Lwt_unix.write_string sock (Char.escaped c) 0 1 in () -- cgit v1.2.3