// Path: src/main/java/pl/domzal/junit/docker/rule/wait/LineListener.java
// public interface LineListener {
//     void nextLine(String line);
// }


import static org.mockito.Mockito.*;
import java.io.IOException;
import java.io.OutputStream;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import pl.domzal.junit.docker.rule.wait.LineListener;
package pl.domzal.junit.docker.rule.logs;





public class LogSplitterTest {

    private static Logger log = LoggerFactory.getLogger(LogSplitterTest.class);

    public static final int NO_OF_LOG_LISTENERS = 3;

    private final ExecutorService executor = Executors.newFixedThreadPool(NO_OF_LOG_LISTENERS);

// Path: src/main/java/pl/domzal/junit/docker/rule/wait/LineListener.java
// public interface LineListener {
//     void nextLine(String line);
// }


// Path: src/test/java/pl/domzal/junit/docker/rule/logs/LogSplitterTest.java
import static org.mockito.Mockito.*;
import java.io.IOException;
import java.io.OutputStream;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import pl.domzal.junit.docker.rule.wait.LineListener;

package pl.domzal.junit.docker.rule.logs;





public class LogSplitterTest {

    private static Logger log = LoggerFactory.getLogger(LogSplitterTest.class);

    public static final int NO_OF_LOG_LISTENERS = 3;

    private final ExecutorService executor = Executors.newFixedThreadPool(NO_OF_LOG_LISTENERS);

    private LineListener combinedLines = mock(LineListener.class);