sketch of a more invasive CompletableFuture patch

src/main/java/ch/vorburger/exec/ProcessResultHandler.java → src/main/java/ch/vorburger/exec/CompletableFutureExecuteResultHandler.java

@@ -19,32 +19,35 @@
  */
 package ch.vorburger.exec;
 
+import java.util.concurrent.CompletableFuture;
 import org.apache.commons.exec.ExecuteException;
+import org.apache.commons.exec.ExecuteResultHandler;
 
-/**
- * Extends {@link AtomicExecuteResultHandler} with a listener.
- */
-class ProcessResultHandler extends AtomicExecuteResultHandler {
-    private final ManagedProcessListener listener;
+class CompletableFutureExecuteResultHandler implements ExecuteResultHandler {
+
+    private final CompletableFuture<Integer> asyncResult;
 
-    ProcessResultHandler(ManagedProcessListener listener) {
-        if (listener == null) {
-            //set internal listener
-            this.listener = new ManagedProcessListenerInternal();
-        } else {
-            this.listener = listener;
-        }
+    public CompletableFutureExecuteResultHandler(CompletableFuture<Integer> asyncResult) {
+        this.asyncResult = asyncResult;
     }
 
+    /**
+    * The asynchronous execution completed.
+    *
+    * @param exitValue the exit value of the sub-process
+    */
     @Override
     public void onProcessComplete(int exitValue) {
-        super.onProcessComplete(exitValue);
-        listener.onProcessComplete(exitValue);
+        asyncResult.complete(exitValue);
     }
 
+    /**
+    * The asynchronous execution failed.
+    *
+    * @param e the {@code ExecuteException} containing the root cause
+    */
     @Override
-    public void onProcessFailed(ExecuteException processFailedException) {
-        super.onProcessFailed(processFailedException);
-        listener.onProcessFailed(processFailedException.getExitValue(), processFailedException);
+    public void onProcessFailed(ExecuteException e) {
+        asyncResult.completeExceptionally(e);
     }
 }