package kafkatimer

import (
	"fmt"
	"testing"
	"time"
)

func F()  {
	fmt.Println("I'm timer...")
}


func TestTimingWheel_Start(t *testing.T) {
	tw := NewTimingWheel(time.Millisecond, 20)
	tw.Start()
	defer tw.Stop()

	exitC := make(chan time.Time, 1)
	tw.AfterFunc(10 * time.Second, func() {
		fmt.Println("The timer fires")
		exitC <- time.Now().UTC()
	})

	fmt.Println(<-exitC)
}