Function TestLoopTimer

tests/timer_test.go:41–67

(t *testing.T)

}

func TestLoopTimer(t *testing.T) {

	signal := NewSignalTester(t)
	signal.SetTimeout(60 * time.Second)

	queue := cellnet.NewEventQueue()

	// 启动消息循环
	queue.StartLoop()

	var count int

	// 启动计时循环
	timer.NewLoop(queue, time.Millisecond*10, func(ctx *timer.Loop) {

		log.Debugln("tick 10 ms", count)

		count++

		if count >= 10 {
			signal.Done(1)
			ctx.Stop()
		}
	}, nil).Start()

	signal.WaitAndExpect("10ms * 10 times ticker not done", 1)
}