import org.zeroturnaround.exec.stream.LogOutputStream; //导入依赖的package包/类
@Test
public void beforeStartListener() throws IOException, InterruptedException, TimeoutException {
    ArrayList<String> lines = new ArrayList<>();
    final String arg = "line1";
    new Cmd()
            .listening()
            .beforeStart(e -> e.redirectOutputAlsoTo(new LogOutputStream() {
                @Override
                protected void processLine(String line) {
                    lines.add(line);
                }
            }))
            .back()
            .command("echo", arg)
            .execute();

    assertEquals(1, lines.size());
    assertEquals(arg, lines.get(0));
}
 

import org.zeroturnaround.exec.stream.LogOutputStream; //导入依赖的package包/类
private void testLogOutputStream(String multiLineString, String... expectedLines) throws UnsupportedEncodingException, IOException {
	final List<String> processedLines = new ArrayList<String>();
	LogOutputStream logOutputStream = new LogOutputStream() {

		@Override
		protected void processLine(String line) {
			processedLines.add(line);
		}
	};
	try {
		logOutputStream.write(multiLineString.getBytes("UTF-8"));
	} finally {
		logOutputStream.close();
	}
	Assert.assertEquals(Arrays.asList(expectedLines), processedLines);
}
 

import org.zeroturnaround.exec.stream.LogOutputStream; //导入依赖的package包/类
void pumpOutputToLogStream(OutputStream out) throws Exception {
  new ProcessExecutor().command("java", "-version")
      .redirectOutput(new LogOutputStream() {
        @Override
        protected void processLine(String line) {
          // ...
        }
      })
      .execute();
}