|
|
|
|
@ -273,6 +273,10 @@ public class ChannelSendOperator<T> extends Mono<Void> implements Scannable {
@@ -273,6 +273,10 @@ public class ChannelSendOperator<T> extends Mono<Void> implements Scannable {
|
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
synchronized (this) { |
|
|
|
|
if (this.state == State.READY_TO_WRITE) { |
|
|
|
|
s.request(n); |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
if (this.writeSubscriber != null) { |
|
|
|
|
if (this.state == State.EMITTING_CACHED_SIGNALS) { |
|
|
|
|
this.demandBeforeReadyToWrite = n; |
|
|
|
|
|