}

    public void test_run_maxBufferSizeConstant() {
        assertEquals(1000, InputStreamThread.MAX_BUFFER_SIZE);
    }

    public void test_run_withMaxBufferSize() throws InterruptedException {
        StringBuilder inputBuilder = new StringBuilder();
        for (int i = 1; i <= 1005; i++) {
            inputBuilder.append("line").append(i).append("\n");
        }