Check queue if premature cancel (could be null)

reactor · May 13, 2019 · d7267e1 · d7267e1
1 parent ad7e545
commit d7267e1
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) {