diff --git a/stream.go b/stream.go index 8323a06..2e84823 100644 --- a/stream.go +++ b/stream.go @@ -226,6 +226,7 @@ func (s *Stream) recycleTokens() (n int) { for k := range s.buffers { total += len(s.buffers[k]) } + s.buffers = nil s.bufferLock.Unlock() return total }