github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[jOOQ/jOOQ#13669] Race conditions also onError()

Browse Source
This commit is contained in:
Lukas Eder 2022-07-04 11:23:26 +02:00
parent 5054443b95
commit 0450b0c00f
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
jOOQ/src/main/java/org/jooq/impl/R2DBC.java
View File

@ -251,7 +251,7 @@ final class R2DBC {
resultSubscriber.downstream.forwarders.remove(forwarderIndex);
// [#13343] [#13669] Prevent premature completion
if (cancelled || resultSubscriber.downstream.forwarders.isEmpty() && resultSubscriber.completionRequested.get())
if (resultSubscriber.downstream.forwarders.isEmpty() && resultSubscriber.completionRequested.get())
resultSubscriber.complete(cancelled);
}
}