Adding lo.WaitFor

[samber]

ok := WaitFor(func(i int) bool {
	return i % 3 == 2
}, 10*time.Millisecond, time.Millisecond)

[codecov-commenter]

Codecov Report

All modified and coverable lines are covered by tests ✅

Project coverage is 94.64%. Comparing base (c23c040) to head (173088f).
Report is 76 commits behind head on master.

Additional details and impacted files

@@            Coverage Diff             @@
##           master     #269      +/-   ##
==========================================
+ Coverage   94.00%   94.64%   +0.64%     
==========================================
  Files          16       17       +1     
  Lines        2500     2892     +392     
==========================================
+ Hits         2350     2737     +387     
- Misses        148      154       +6     
+ Partials        2        1       -1     

Flag	Coverage Δ
unittests	94.64% <100.00%> (+0.64%)	⬆️

Flags with carried forward coverage won't be shown. Click here to find out more.

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[ccoVeille]

What about this

Suggested change

	func WaitFor(condition func(i int) bool, maxDuration time.Duration, tick time.Duration) (int, time.Duration, bool) {
	func WaitFor(condition func(i int) bool, maxDuration time.Duration, tick time.Duration) (int, time.Duration, bool) {
	return WaitForWithCtx(context.Background(), condition, maxDuration, tick)
	}
	// WaitForWithCtx runs periodically until a condition is validated or context is cancelled
	func WaitForWithCtx(ctx context.Context, condition func(i int) bool, maxDuration time.Duration, tick time.Duration) (int, time.Duration, bool) {
	if condition(0) {
	return 1, 0, true
	}
	start := time.Now()
	timer := time.NewTimer(maxDuration)
	ticker := time.NewTicker(tick)
	defer func() {
	timer.Stop()
	ticker.Stop()
	}()
	i := 1
	for {
	select {
	case <-ctx.Done():
	return i, time.Since(start), false
	case <-timer.C:
	return i, time.Since(start), false
	case <-ticker.C:
	if condition(i) {
	return i + 1, time.Since(start), true
	}
	i++
	}
	}
	}

[ccoVeille]

@samber

[samber]

Please open a new PR.

[ccoVeille]

I opened

• feat: add WaitForWithContext #480