kubernetes/staging/src/k8s.io/apimachinery/pkg/util/wait/loop_test.go

func timerWithClock(t Timer, c clock.WithTicker) Timer { … }

func Test_loopConditionWithContextImmediateDelay(t *testing.T) { … }

func Test_loopConditionUntilContext_semantic(t *testing.T) { … }

type timerWrapper …

func (w *timerWrapper) C() <-chan time.Time { … }

func (w *timerWrapper) Stop() bool          { … }

func (w *timerWrapper) Reset(d time.Duration) bool { … }

func Test_loopConditionUntilContext_timings(t *testing.T) { … }

// Test_loopConditionUntilContext_timings runs actual timing loops and calculates the delta. This
// test depends on high precision wakeups which depends on low CPU contention so it is not a
// candidate to run during normal unit test execution (nor is it a benchmark or example). Instead,
// it can be run manually if there is a scenario where we suspect the timings are off and other
// tests haven't caught it. A final sanity test that would have to be run serially in isolation.
func Test_loopConditionUntilContext_Elapsed(t *testing.T) { … }

func Benchmark_loopConditionUntilContext_ZeroDuration(b *testing.B) { … }

func Benchmark_loopConditionUntilContext_ShortDuration(b *testing.B) { … }