Skip to content

Commit d47df4e

Browse files
ktosoviktorklang
authored andcommitted
=tck flop eagerly
1 parent dc409bf commit d47df4e

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

Diff for: tck/src/main/java/org/reactivestreams/tck/TestEnvironment.java

+2
Original file line numberDiff line numberDiff line change
@@ -907,6 +907,8 @@ public void complete(T value) {
907907
if (_value.compareAndSet(null, value)) {
908908
// we add the value to the queue such to wake up any expectCompletion which was triggered before complete() was called
909909
abq.add(value);
910+
} else {
911+
env.flop(String.format("Cannot complete a promise more than once! Present value: %s", value));
910912
}
911913
}
912914

0 commit comments

Comments
 (0)