Receive thrownException in RemoteProgressBarReceiver

openrewrite · Oct 8, 2023 · 6d5c47d · 6d5c47d
1 parent fa41e6e
commit 6d5c47d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/main/java/org/openrewrite/polyglot/RemoteProgressBarReceiver.java b/src/main/java/org/openrewrite/polyglot/RemoteProgressBarReceiver.java
@@ -66,6 +66,11 @@ protected boolean removeEldestEntry(Map.Entry<UUID, RemoteProgressMessage> eldes
                 }
 
                 switch (message.getType()) {
+                    case Exception:
+                        if (message.getMessage() != null) {
+                            throw RemoteException.decode(message.getMessage());
+                        }
+                        break;
                     case IntermediateResult:
                         delegate.intermediateResult(message.getMessage());
                         break;