diff --git a/cffu-core/src/main/java/io/foldright/cffu/Cffu.java b/cffu-core/src/main/java/io/foldright/cffu/Cffu.java index 3f8637c6..f26f175d 100644 --- a/cffu-core/src/main/java/io/foldright/cffu/Cffu.java +++ b/cffu-core/src/main/java/io/foldright/cffu/Cffu.java @@ -996,7 +996,8 @@ public Cffu orTimeout(Executor executorWhenTimeout, long timeout, TimeUnit un */ public Cffu unsafeOrTimeout(long timeout, TimeUnit unit) { checkMinimalStage(); - return reset0(CompletableFutureUtils.orTimeout(cf, timeout, unit)); + CompletableFutureUtils.orTimeout(cf, timeout, unit); + return this; } /** @@ -1054,7 +1055,8 @@ public Cffu completeOnTimeout(@Nullable T value, Executor executorWhenTimeout */ public Cffu unsafeCompleteOnTimeout(@Nullable T value, long timeout, TimeUnit unit) { checkMinimalStage(); - return reset0(CompletableFutureUtils.completeOnTimeout(cf, value, timeout, unit)); + CompletableFutureUtils.completeOnTimeout(cf, value, timeout, unit); + return this; } ////////////////////////////////////////////////////////////////////////////////