diff options
| author | Clombrong <cromblong@egregore.fun> | 2025-06-28 01:08:31 +0200 |
|---|---|---|
| committer | Clombrong <cromblong@egregore.fun> | 2025-06-28 07:39:19 +0200 |
| commit | 979290eff020f00ab207013ebb390b3cedb86840 (patch) | |
| tree | 9954e9e4f9591ad8def7efed76dc5865f4dd8bcf | |
| parent | d5725c16b8e92b4d0ba5edc9edc25c273a9ccf29 (diff) | |
chore(portal_tcp): socket_to_stream: rename buffer into recv_bytes
| -rw-r--r-- | portal/tcp/portal.ml | 6 |
1 files changed, 3 insertions, 3 deletions
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 () |