Function TestAfterTimer

tests/timer_test.go:11–39

(t *testing.T)

)

func TestAfterTimer(t *testing.T) {

	signal := NewSignalTester(t)

	queue := cellnet.NewEventQueue()

	queue.StartLoop()

	timer.After(queue, 100*time.Millisecond, func() {
		log.Debugln("after 100 ms")

		signal.Done(1)
	}, nil)

	timer.After(queue, 200*time.Millisecond, func(context interface{}) {

		if context.(string) != "context" {
			t.FailNow()
		}

		log.Debugln("after 200 ms")

		signal.Done(2)
	}, "context")

	signal.WaitAndExpect("100ms after not done", 1)

	signal.WaitAndExpect("200ms after not done", 2)
}

func TestLoopTimer(t *testing.T) {