record failures

Author: snazy

api/client/src/testFixtures/java/org/projectnessie/client/auth/oauth2/InteractiveResourceOwnerEmulator.java

@@ -39,6 +39,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
@@ -90,7 +91,18 @@ public InteractiveResourceOwnerEmulator(String username, String password, SSLCon
         Executors.newFixedThreadPool(
             2, r -> new Thread(r, getClass().getSimpleName() + COUNTER.getAndIncrement()));
     standardOut = System.out;
-    executor.submit(this::readConsole);
+    submitAndRecordFailure(this::readConsole);
+  }
+
+  protected void submitAndRecordFailure(Runnable runnable) {
+    CompletableFuture.runAsync(runnable, executor)
+        .whenComplete(
+            (r, ex) -> {
+              if (ex != null) {
+                LOGGER.error("Error in async job", ex);
+                recordFailure(ex);
+              }
+            });
   }
 
   @Override
@@ -127,7 +139,7 @@ private void readConsole() {
         standardOut.flush();
         Runnable flow = processLine(line);
         if (flow != null) {
-          executor.submit(flow);
+          submitAndRecordFailure(flow);
         }
       }
     } catch (IOException ignored) {