fix #413 When it is the last drained element do not schedule the flus…

…h operation
reactor · Aug 22, 2018 · 9242735 · 9242735
1 parent e079cab
commit 9242735
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/reactor/ipc/netty/channel/ChannelOperationsHandler.java b/src/main/java/reactor/ipc/netty/channel/ChannelOperationsHandler.java
@@ -291,7 +291,9 @@ ChannelFuture doWrite(Object msg, ChannelPromise promise, PublisherSender inner)
 			pendingBytes = 0L;
 
 			ChannelFuture future = ctx.write(msg, promise);
-			if (flushOnEachWithEventLoop && ctx.channel().isWritable()) {
+			if (flushOnEachWithEventLoop &&
+					!(inner == null && pendingWrites.isEmpty()) &&
+					ctx.channel().isWritable()) {
 				scheduleFlush();
 			}
 			else {