diff --git a/README.md b/README.md
index cfe8227..e376e74 100644
--- a/README.md
+++ b/README.md
@@ -45,22 +45,22 @@ dependencies {
dev.tommyjs
futur-api
- 1.0.0
+ 2.1.1
dev.tommyjs
futur-standalone
- 1.0.0
+ 2.1.1
dev.tommyjs
futur-reactor
- 1.0.0
+ 2.1.1
dev.tommyjs
futur-reactive-streams
- 1.0.0
+ 2.1.1
```
diff --git a/futur-api/build.gradle.kts b/futur-api/build.gradle.kts
index 9495788..9e1f36b 100644
--- a/futur-api/build.gradle.kts
+++ b/futur-api/build.gradle.kts
@@ -6,7 +6,7 @@ plugins {
}
group = "dev.tommyjs"
-version = "2.1.0"
+version = "2.1.1"
repositories {
mavenCentral()
diff --git a/futur-api/src/main/java/dev/tommyjs/futur/promise/AbstractPromise.java b/futur-api/src/main/java/dev/tommyjs/futur/promise/AbstractPromise.java
index f38e838..2cd548d 100644
--- a/futur-api/src/main/java/dev/tommyjs/futur/promise/AbstractPromise.java
+++ b/futur-api/src/main/java/dev/tommyjs/futur/promise/AbstractPromise.java
@@ -13,6 +13,7 @@ import java.util.Collection;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
+import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
public abstract class AbstractPromise implements Promise {
@@ -316,13 +317,14 @@ public abstract class AbstractPromise implements Promise {
}
protected void handleCompletion(@NotNull PromiseCompletion ctx) {
- AtomicReference success = new AtomicReference<>();
+ AtomicBoolean success = new AtomicBoolean();
completion.getAndUpdate(c -> {
if (c == null) {
- return null;
- } else {
success.set(true);
return ctx;
+ } else {
+ success.set(false);
+ return c;
}
});
@@ -339,7 +341,6 @@ public abstract class AbstractPromise implements Promise {
try {
listener.handle(ctx);
} catch (Exception e) {
- e.printStackTrace();
getLogger().error("Exception caught in promise listener", e);
}
}
diff --git a/futur-reactive-streams/build.gradle.kts b/futur-reactive-streams/build.gradle.kts
index f2b84f3..ddea3d8 100644
--- a/futur-reactive-streams/build.gradle.kts
+++ b/futur-reactive-streams/build.gradle.kts
@@ -6,7 +6,7 @@ plugins {
}
group = "dev.tommyjs"
-version = "2.1.0"
+version = "2.1.1"
repositories {
mavenCentral()
diff --git a/futur-reactor/build.gradle.kts b/futur-reactor/build.gradle.kts
index 804b69d..b72f5e3 100644
--- a/futur-reactor/build.gradle.kts
+++ b/futur-reactor/build.gradle.kts
@@ -4,7 +4,7 @@ plugins {
}
group = "dev.tommyjs"
-version = "2.1.0"
+version = "2.1.1"
repositories {
mavenCentral()