@@ -0,0 +1,851 @@
+package org.textfiledatatools.core.logger;%0A%0Aimport org.textfiledatatools.core.Record;%0A%0Aimport java.util.Objects;%0Aimport java.util.concurrent.atomic.AtomicInteger;%0A%0A/**%0A * @author Mathias Kalb%0A * @since 0.1%0A */%0Apublic class LimitedLogger%3CT extends Record%3E implements RecordLogger%3CT%3E %7B%0A%0A    private final RecordLogger%3CT%3E recordLogger;%0A    private final int limit;%0A    private final AtomicInteger counter;%0A%0A    public LimitedLogger(RecordLogger%3CT%3E recordLogger, int limit) %7B%0A        Objects.requireNonNull(recordLogger);%0A        this.recordLogger = recordLogger;%0A        this.limit = limit;%0A        this.counter = new AtomicInteger(0);%0A    %7D%0A%0A    @Override%0A    public void log(T record) %7B%0A        if (counter.get() %3C limit) %7B%0A            if (counter.getAndIncrement() %3C limit) %7B%0A                recordLogger.log(record);%0A            %7D%0A        %7D%0A    %7D%0A%0A%7D%0A

Add LimitedLogger