public void awaitTermination(long timeout, TimeUnit unit)
      throws InterruptedException, ExecutionException, TimeoutException {
    if (processInputTask != null) {
      processInputTask.get(timeout, unit);
    }
  }
Blocks until the StreamGobbler finishes processing the input stream

@throws InterruptedException if the StreamGobbler thread was interrupted
@throws ExecutionException if the StreamGobbler thread threw an exception
@throws TimeoutException if the StreamGobbler does not finish processing input before the
        timeout
geode-junit/src/main/java/org/apache/geode/test/junit/rules/gfsh/internal/StreamGobbler.java