in core/src/main/java/org/apache/commons/functor/aggregator/AbstractTimedAggregator.java [418:430]
private void timer() {
if (timerListeners != null) {
// if we have listeners, notify them
T aggregated = evaluate(); // NOTE: shouldn't evaluate() and reset()
// be done atomically here?
reset();
for (TimedAggregatorListener<T> i : timerListeners) {
i.onTimer(this, aggregated);
}
} else {
reset();
}
}