diff options
| author |  Ciro Spaciari <ciro.spaciari@gmail.com>
| 2023-01-26 20:08:34 -0300 |
|---|---|---|
| committer |  GitHub <noreply@github.com>
| 2023-01-26 15:08:34 -0800 |
| commit | b32b0b87369c16e98c3402abb1d7ffd54c835f34 (patch) | |
| tree | 4765605f7931564ac70b5d60707f24fef5ca36e0 /src/http/websocket_http_client.zig | |
| parent | fbe45fcb037fa561692939a2066ca4c4e0223ff7 (diff) | |
| download | bun-b32b0b87369c16e98c3402abb1d7ffd54c835f34.tar.gz bun-b32b0b87369c16e98c3402abb1d7ffd54c835f34.tar.zst bun-b32b0b87369c16e98c3402abb1d7ffd54c835f34.zip | |
fix large packages receive for WS client (#1909)
Diffstat (limited to 'src/http/websocket_http_client.zig')
| -rw-r--r-- | src/http/websocket_http_client.zig | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/http/websocket_http_client.zig b/src/http/websocket_http_client.zig index 6692b8c87..bc72f9e56 100644 --- a/src/http/websocket_http_client.zig +++ b/src/http/websocket_http_client.zig @@ -986,7 +986,7 @@ pub fn NewWebSocketClient(comptime ssl: bool) type { @memcpy(writable.ptr, data_.ptr, data_.len); this.receive_buffer.update(data_.len); - if (left_in_fragment > data_.len and left_in_fragment - data_.len - this.receive_pending_chunk_len == 0) { + if (left_in_fragment >= data_.len and left_in_fragment - data_.len - this.receive_pending_chunk_len == 0) { this.receive_pending_chunk_len = 0; this.dispatchData(this.receive_buffer.readableSlice(0), kind); this.clearReceiveBuffers(false); |