in timebucket.go [38:49]
func (b *TimeBucket) tick() bool {
var newEndTime = b.endTime.Add(b.size)
var nowWithAdjustedDelay = time.Now().Add(-b.delay).Round(b.size)
// Only tick if we can still keep our delay!
if newEndTime.Before(nowWithAdjustedDelay) || newEndTime.Equal(nowWithAdjustedDelay) {
b.endTime = newEndTime
return true
} else {
return false
}
}