Merge branch '6.2.x'

This commit is contained in:
Stéphane Nicoll
2024-12-10 07:48:01 +01:00
4 changed files with 8 additions and 8 deletions

View File

@@ -181,7 +181,7 @@ class ChannelSendOperator<T> extends Mono<Void> implements Scannable {
requiredWriteSubscriber().onNext(item);
return;
}
//FIXME revisit in case of reentrant sync deadlock
// FIXME revisit in case of reentrant sync deadlock
synchronized (this) {
if (this.state == State.READY_TO_WRITE) {
requiredWriteSubscriber().onNext(item);