From e2f59fa956da647d6e640a2580cf47455441694f Mon Sep 17 00:00:00 2001 From: Son Roy Almerol Date: Sun, 22 Sep 2024 20:18:13 -0400 Subject: [PATCH] fix force buffer --- proxy/buffer.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/proxy/buffer.go b/proxy/buffer.go index 192c5d6..7788010 100644 --- a/proxy/buffer.go +++ b/proxy/buffer.go @@ -38,9 +38,11 @@ func (b *Buffer) ReadChunk(size int, force bool) ([]byte, bool) { defer b.mu.Unlock() // Wait for buffer to have enough data - if !force { - for len(b.data) < size { - b.cond.Wait() + for len(b.data) < size { + b.cond.Wait() + if force { + size = len(b.data) + break } }