String output = thread.getOutput();
        assertTrue("Buffer should contain line before callback exception", output.contains("test line"));
    }

    @Test
    public void test_run_nullCallback() throws InterruptedException {
        String input = "test line";
        InputStream is = new ByteArrayInputStream(input.getBytes(StandardCharsets.UTF_8));