Skip to content

Commit

Permalink
change: expose internal futures
Browse files Browse the repository at this point in the history
  • Loading branch information
ishland committed Aug 5, 2024
1 parent bd4e703 commit bac4163
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions src/main/java/com/ishland/flowsched/scheduler/ItemHolder.java
Original file line number Diff line number Diff line change
Expand Up @@ -256,6 +256,13 @@ public K getKey() {
public synchronized CompletableFuture<Void> getFutureForStatus(ItemStatus<K, V, Ctx> status) {
return this.futures[status.ordinal()].thenApply(Function.identity());
}

/**
* Only for trusted methods
*/
public synchronized CompletableFuture<Void> getFutureForStatus0(ItemStatus<K, V, Ctx> status) {
return this.futures[status.ordinal()];
}

public AtomicReference<V> getItem() {
return this.item;
Expand Down

0 comments on commit bac4163

Please sign in to comment.