Method NewTicker

internal/ztest/clock.go:68–89

NewTicker returns a time.Ticker that ticks at the specified frequency. As with [time.NewTicker], the ticker will drop ticks if the receiver is slow, and the channel is never closed. Calling Stop on the returned ticker is a no-op. The ticker only runs when the clock is advanced.

(d time.Duration)

// Calling Stop on the returned ticker is a no-op.
// The ticker only runs when the clock is advanced.
func (c *MockClock) NewTicker(d time.Duration) *time.Ticker {
	ch := make(chan time.Time, 1)

	var tick func(time.Time)
	tick = func(now time.Time) {
		next := now.Add(d)
		c.runAt(next, func() {
			defer tick(next)

			select {
			case ch <- next:
				// ok
			default:
				// The receiver is slow.
				// Drop the tick and continue.
			}
		})
	}
	tick(c.Now())

	return &time.Ticker{C: ch}
}

// runAt schedules the given function to be run at the given time.
// The function runs without a lock held, so it may schedule more work.