diff --git a/sync/adaptivewaitgroup.go b/sync/adaptivewaitgroup.go index ecd50efe..71c66ced 100644 --- a/sync/adaptivewaitgroup.go +++ b/sync/adaptivewaitgroup.go @@ -69,4 +69,5 @@ func (s *AdaptiveWaitGroup) Wait() { func (s *AdaptiveWaitGroup) Resize(size int) { s.current.Resize(channels.BufferCap(size)) + s.Size = int(s.current.Cap()) }