Method advanceClock

subscriber/common/tools/batcher_test.go:37–41

(duration time.Duration)

}

func (w *worker) advanceClock(duration time.Duration) {
	w.mutex.Lock()
	defer w.mutex.Unlock()
	w.time = w.time.Add(duration)
}

func (w *worker) run(batches chan []interface{}, wg *sync.WaitGroup) {
	for batch := range batches {