vavr-io#2552 Condition to not execute actions if future is cancelled

charvakcpatel007 · Jul 27, 2020 · 8cd98c3 · 8cd98c3
1 parent 0b7a72c
commit 8cd98c3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/io/vavr/concurrent/FutureImpl.java b/src/main/java/io/vavr/concurrent/FutureImpl.java
@@ -376,6 +376,9 @@ boolean tryComplete(Try<? extends T> value) {
             if (waiters != null) {
                 waiters.forEach(this::unlock);
             }
+            if(isCancelled()) {
+                return true;
+            }
             if (actions != null) {
                 actions.forEach(this::perform);
                 return true;