Fix recently intorduced bug in ChannelSendOperator

WriteBarrier acts as Subscription to both completionSubscriber and
writeSubscriber so the request method needs to be careful not to
pass on the request outside of readyToWrite or writeSubscriber checks.
This commit is contained in:
Rossen Stoyanchev 2017-07-12 12:40:51 +02:00
parent fbcd554f42
commit 89a5c857ac
1 changed files with 1 additions and 1 deletions

View File

@ -229,9 +229,9 @@ public class ChannelSendOperator<T> extends Mono<Void> implements Scannable {
if (n == 0) {
return;
}
s.request(n);
}
}
s.request(n);
}
private boolean emitCachedSignals() {