// Path: src/main/java/de/wellnerbou/chronic/logparser/LogLineParser.java
// public interface LogLineParser {
// 
// 	LogLineData parseLine(Object logLine);
// 	String getId();
// }
// 
// Path: src/main/java/de/wellnerbou/chronic/logsource/LogSourceReader.java
// public interface LogSourceReader<T> extends Closeable {
// 	T next();
// }
// 
// Path: src/main/java/de/wellnerbou/chronic/logsource/factory/LogSourceReaderFactory.java
// public interface LogSourceReaderFactory {
// 	String getId();
// 	LogSourceReader create(InputStream is);
// }


import com.ning.http.client.ListenableFuture;
import com.ning.http.client.Response;
import de.wellnerbou.chronic.logparser.LogLineParser;
import de.wellnerbou.chronic.logsource.LogSourceReader;
import de.wellnerbou.chronic.logsource.factory.LogSourceReaderFactory;
import org.joda.time.DateTime;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.io.InputStream;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;
package de.wellnerbou.chronic.replay;



public class LogReplayReader {

    private static final Logger LOG = LoggerFactory.getLogger(LogReplayReader.class);

    private final LineReplayer lineReplayer;
// Path: src/main/java/de/wellnerbou/chronic/logparser/LogLineParser.java
// public interface LogLineParser {
// 
// 	LogLineData parseLine(Object logLine);
// 	String getId();
// }
// 
// Path: src/main/java/de/wellnerbou/chronic/logsource/LogSourceReader.java
// public interface LogSourceReader<T> extends Closeable {
// 	T next();
// }
// 
// Path: src/main/java/de/wellnerbou/chronic/logsource/factory/LogSourceReaderFactory.java
// public interface LogSourceReaderFactory {
// 	String getId();
// 	LogSourceReader create(InputStream is);
// }


// Path: src/main/java/de/wellnerbou/chronic/replay/LogReplayReader.java
import com.ning.http.client.ListenableFuture;
import com.ning.http.client.Response;
import de.wellnerbou.chronic.logparser.LogLineParser;
import de.wellnerbou.chronic.logsource.LogSourceReader;
import de.wellnerbou.chronic.logsource.factory.LogSourceReaderFactory;
import org.joda.time.DateTime;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.io.InputStream;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;

package de.wellnerbou.chronic.replay;



public class LogReplayReader {

    private static final Logger LOG = LoggerFactory.getLogger(LogReplayReader.class);

    private final LineReplayer lineReplayer;
    private final LogLineParser logLineParser;