修正FutureHelper.isError的实现

entropy-cloud · Jan 13, 2025 · a173304 · a173304
1 parent e0328af
commit a173304
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/nop-api-core/src/main/java/io/nop/api/core/util/FutureHelper.java b/nop-api-core/src/main/java/io/nop/api/core/util/FutureHelper.java
@@ -439,7 +439,10 @@ private static boolean isSuccess(CompletionStage<?> f) {
     public static boolean isError(CompletionStage<?> f) {
         if (f instanceof ResolvedPromise)
             return ((ResolvedPromise<?>) f).getException() != null;
-        return true;
+        if (f instanceof CompletableFuture) {
+            return ((CompletableFuture<?>) f).isCompletedExceptionally();
+        }
+        return false;
     }
 
     public static CompletableFuture<?> waitAnySuccess(Collection<? extends CompletionStage> futures) {