Function DrainReady

cel/async/async.go:82–84

DrainReady returns a strategy that waits for a short duration after the first completion to batch any other functions that complete at roughly the same time.

(debounce time.Duration)

// DrainReady returns a strategy that waits for a short duration after the first
// completion to batch any other functions that complete at roughly the same time.
func DrainReady(debounce time.Duration) DrainStrategy {
	return drainReady{debounce: debounce}
}

type drainReady struct {
	debounce time.Duration