Merge branch '0.8.x'

reactor · May 14, 2019 · 1e08b10 · 1e08b10
2 parents 35052c7 + d7267e1
commit 1e08b10
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/main/java/reactor/netty/channel/MonoSendMany.java b/src/main/java/reactor/netty/channel/MonoSendMany.java
@@ -337,6 +337,10 @@ void cleanup() {
 			   .removeListener(this);
 
 			Context context = actual.currentContext();
+			Queue<I> queue = this.queue;
+			if (queue == null) {
+				return;
+			}
 			while (!queue.isEmpty()) {
 				I sourceMessage = queue.poll();
 				if (sourceMessage != null) {