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)
  }