in core/src/main/java/com/spotify/metrics/core/OverwritingFixedConcurrentRingBuffer.java [93:102]
public <R> List<R> getSnapshot(final Predicate<T> filter, final Function<T, R> mapper) {
final ArrayList<R> res = new ArrayList<>(capacity);
for (int i = 0; i < capacity; i++) {
final T element = buffer.get(i);
if (filter.test(element)) {
res.add(mapper.apply(element));
}
}
return res;
}