Method now

subscriber/common/tools/batcher_test.go:31–35

()

}

func (w *worker) now() time.Time {
	w.mutex.Lock()
	defer w.mutex.Unlock()
	return w.time
}

func (w *worker) advanceClock(duration time.Duration) {
	w.mutex.Lock()