fixed doneCh buffer size

This commit is contained in:
milarin 2023-03-06 14:17:49 +01:00
parent 3cb1984024
commit acfe7532d1

View File

@ -33,7 +33,7 @@ func NewForWriter[K comparable](w io.Writer) *View[K] {
taskMap: map[K]struct{}{}, taskMap: map[K]struct{}{},
reportCh: make(chan report[K], 100), reportCh: make(chan report[K], 100),
doneCh: make(chan struct{}), doneCh: make(chan struct{}, 1),
lastReports: map[K]report[K]{}, lastReports: map[K]report[K]{},
wg: &sync.WaitGroup{}, wg: &sync.WaitGroup{},
} }