diff --git a/common/bufio/chunk.go b/common/bufio/chunk.go index 048a372b..870c54b1 100644 --- a/common/bufio/chunk.go +++ b/common/bufio/chunk.go @@ -22,6 +22,10 @@ func NewChunkReader(upstream io.Reader, maxChunkSize int) *ChunkReader { } func (c *ChunkReader) ReadBuffer(buffer *buf.Buffer) error { + if c.cache != nil && !c.cache.IsEmpty() { + return common.Error(buffer.ReadFrom(c.cache)) + } + if buffer.FreeLen() >= c.maxChunkSize { return c.upstream.ReadBuffer(buffer) }