From 37475dac47cc33b56252854bd67de91a819d2d66 Mon Sep 17 00:00:00 2001 From: Jacob Quinn Date: Tue, 24 Sep 2024 11:11:18 -0600 Subject: [PATCH] Also call increment read window from eof call on Client socket --- src/sockets/client.jl | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/sockets/client.jl b/src/sockets/client.jl index f4c48a1..9979559 100644 --- a/src/sockets/client.jl +++ b/src/sockets/client.jl @@ -357,7 +357,12 @@ function Base.skip(sock::Client, n) end Base.bytesavailable(sock::Client) = bytesavailable(sock.readbuf) -Base.eof(sock::Client) = eof(sock.readbuf) + +function Base.eof(sock::Client) + maybe_increment_read_window(sock, 0) + eof(sock.readbuf) +end + Base.isopen(sock::Client) = sock.slot == C_NULL ? false : aws_socket_is_open(aws_socket_handler_get_socket(FieldRef(sock, :handler))) function Base.readbytes!(sock::Client, buf::AbstractVector{UInt8}, nb=length(buf))