tommyskeff/futur4j
1
0
Fork 0
mirror of https://github.com/tommyskeff/futur4j.git synced 2026-01-18 07:16:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

add more direct listener methods

Browse Source
This commit is contained in:
WhatCats
2024-05-25 21:17:14 +02:00
parent 363669d2c6
commit 4251f2fd82
2 changed files with 62 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
futur-api/src/main/java/dev/tommyjs/futur/promise/AbstractPromise.java
View File

@@ -103,6 +103,58 @@ public abstract class AbstractPromise<T, F> implements Promise<T> {
return completion.getResult();
}
@Override
public @NotNull Promise<Void> thenRun(@NotNull ExceptionalRunnable task) {
return thenApply(result -> {
task.run();
return null;
});
}
@Override
public @NotNull Promise<Void> thenConsume(@NotNull ExceptionalConsumer<T> task) {
return thenApply(result -> {
task.accept(result);
return null;
});
}
@Override
public <V> @NotNull Promise<V> thenSupply(@NotNull ExceptionalSupplier<V> task) {
return thenApply(result -> task.get());
}
@Override
public <V> @NotNull Promise<V> thenApply(@NotNull ExceptionalFunction<T, V> task) {
Promise<V> promise = getFactory().unresolved();
addDirectListener(
res -> createRunnable(res, promise, task).run(),
promise::completeExceptionally
);
propagateCancel(promise, this);
return promise;
}
@Override
public <V> @NotNull Promise<V> thenCompose(@NotNull ExceptionalFunction<T, Promise<V>> task) {
Promise<V> promise = getFactory().unresolved();
thenApply(task).addDirectListener(
nestedPromise -> {
if (nestedPromise == null) {
promise.complete(null);
} else {
propagateResult(nestedPromise, promise);
propagateCancel(promise, nestedPromise);
}
},
promise::completeExceptionally
);
propagateCancel(promise, this);
return promise;
}
@Override
public @NotNull Promise<Void> thenRunSync(@NotNull ExceptionalRunnable task) {
return thenApplySync(result -> {

10
futur-api/src/main/java/dev/tommyjs/futur/promise/Promise.java
View File

@@ -19,6 +19,16 @@ public interface Promise<T> {
PromiseFactory getFactory();
@NotNull Promise<Void> thenRun(@NotNull ExceptionalRunnable task);
@NotNull Promise<Void> thenConsume(@NotNull ExceptionalConsumer<T> task);
<V> @NotNull Promise<V> thenSupply(@NotNull ExceptionalSupplier<V> task);
<V> @NotNull Promise<V> thenApply(@NotNull ExceptionalFunction<T, V> task);
<V> @NotNull Promise<V> thenCompose(@NotNull ExceptionalFunction<T, Promise<V>> task);
@NotNull Promise<Void> thenRunSync(@NotNull ExceptionalRunnable task);
@NotNull Promise<Void> thenRunDelayedSync(@NotNull ExceptionalRunnable task, long delay, @NotNull TimeUnit unit);