We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dc409bf commit d47df4eCopy full SHA for d47df4e
tck/src/main/java/org/reactivestreams/tck/TestEnvironment.java
@@ -907,6 +907,8 @@ public void complete(T value) {
907
if (_value.compareAndSet(null, value)) {
908
// we add the value to the queue such to wake up any expectCompletion which was triggered before complete() was called
909
abq.add(value);
910
+ } else {
911
+ env.flop(String.format("Cannot complete a promise more than once! Present value: %s", value));
912
}
913
914
0 commit comments