Function TestMockClock_NewTicker

internal/ztest/clock_test.go:31–57

(t *testing.T)

)

func TestMockClock_NewTicker(t *testing.T) {
	var n atomic.Int32
	clock := NewMockClock()

	done := make(chan struct{})
	defer func() { <-done }() // wait for end

	quit := make(chan struct{})
	// Create a channel to increment every microsecond.
	go func(ticker *time.Ticker) {
		defer close(done)
		for {
			select {
			case <-quit:
				ticker.Stop()
				return
			case <-ticker.C:
				n.Add(1)
			}
		}
	}(clock.NewTicker(time.Microsecond))

	// Move clock forward.
	clock.Add(2 * time.Microsecond)
	assert.Equal(t, int32(2), n.Load())
	close(quit)
}

func TestMockClock_NewTicker_slowConsumer(t *testing.T) {
	clock := NewMockClock()