Skip to content

Commit 98711db

Browse files
committed
CF work
1 parent 9159c3f commit 98711db

File tree

1 file changed

+1
-2
lines changed
  • src/main/java/org/dataloader/orchestration

1 file changed

+1
-2
lines changed

src/main/java/org/dataloader/orchestration/CF.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,7 @@ public <U> CF<U> compose(BiFunction<? super T, Throwable, ? extends U> fn, Execu
109109

110110
public boolean complete(T value) {
111111
boolean success = result.compareAndSet(null, value);
112+
fireDependentActions();
112113
return success;
113114
}
114115

@@ -150,8 +151,6 @@ private <T, U> void completeViaMapper(BiFunction<? super T, Throwable, ? extends
150151
} catch (Throwable t) {
151152
encodeAndSetResult(t);
152153
}
153-
154-
155154
}
156155

157156

0 commit comments

Comments
 (0)