diff options
Diffstat (limited to 'portal/tcp/portal.ml')
| -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 () |