diff --git a/lib/sync/wait/wait.go b/lib/sync/wait/wait.go index 5e0ecf2..1fb99a7 100644 --- a/lib/sync/wait/wait.go +++ b/lib/sync/wait/wait.go @@ -28,7 +28,7 @@ func (w *Wait) Wait() { // WaitWithTimeout blocks until the WaitGroup counter is zero or timeout // returns true if timeout func (w *Wait) WaitWithTimeout(timeout time.Duration) bool { - c := make(chan bool) + c := make(chan bool, 1) go func() { defer close(c) w.wg.Wait()