From 0d5803262e83c7a909e46c8d5ab5e44b1db0f415 Mon Sep 17 00:00:00 2001 From: Tommy Date: Tue, 12 Mar 2024 08:38:20 +0000 Subject: [PATCH] hotfix 2.1.1 --- README.md | 8 ++++---- futur-api/build.gradle.kts | 2 +- .../java/dev/tommyjs/futur/promise/AbstractPromise.java | 9 +++++---- futur-reactive-streams/build.gradle.kts | 2 +- futur-reactor/build.gradle.kts | 2 +- 5 files changed, 12 insertions(+), 11 deletions(-) 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()