When it is the last drained element do not schedule the flush operation

Related to #413
reactor · Aug 23, 2018 · 43d5261 · 43d5261
1 parent e079cab
commit 43d5261
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 {