multitick_test.go

package multitick

// Copyright (c) 2013 VividCortex, Inc. All rights reserved.
// Please see the LICENSE file for applicable license terms.

import (
	"testing"
	"time"
)

func TestTicker(t *testing.T) {
	tick := NewTicker(time.Second, time.Millisecond*250)
	c := tick.Subscribe()
	chans := make([]<-chan time.Time, 0)
	i := 0
	for now := range c {
		chans = append(chans, tick.Subscribe())
		if i > 5 {
			tick.Stop()
			break
		}
		i++
		t.Log(now, now.Nanosecond())
		if now.Nanosecond() < 247000000 || now.Nanosecond() > 253000000 {
			t.Errorf("%v isn't within 3ms of 250ms offset", now)
		}
	}
}

func TestDropped(t *testing.T) {
	tick := NewTicker(time.Millisecond, 0)
	tick.Subscribe()
	time.Sleep(time.Second)
	tick.Stop()
	t.Log(tick.Dropped())
	if tick.Dropped() < 800 {
		t.Errorf("got %v dropped ticks, wanted at least 800", tick.Dropped())
	}
}