Function waitFunc

workerpool_usage_test.go:196–216

nolint

(f func(), exitDelay time.Duration)

//nolint
func waitFunc(f func(), exitDelay time.Duration) error {
	funcDone := make(chan struct{})
	go func() {
		defer close(funcDone)
		f()
	}()

	if exitDelay <= 0 {
		<-funcDone

		return nil
	}

	select {
	case <-time.After(exitDelay):
		return ErrTimeout
	case <-funcDone:
	}

	return nil
}

var (
	ErrTimeout = errors.New(`TIMEOUT`)