diff --git a/common/buf/io.go b/common/buf/io.go index 6b35052d2..4f0e64f99 100644 --- a/common/buf/io.go +++ b/common/buf/io.go @@ -73,7 +73,7 @@ func (r *TimeoutWrapperReader) ReadMultiBufferTimeout(duration time.Duration) (M } return r.mb, r.err case <-timeout: - return nil, nil + return nil, ErrReadTimeout } }