diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteFlushProcessor.java b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteFlushProcessor.java
index 42797152a6..00de5e141e 100644
--- a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteFlushProcessor.java
+++ b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteFlushProcessor.java
@@ -98,7 +98,9 @@ public abstract class AbstractListenerWriteFlushProcessor<T> implements Processo
 	 * Listeners can call this method to cancel further writing.
 	 */
 	protected void cancel() {
-		this.subscription.cancel();
+		if (this.subscription != null) {
+			this.subscription.cancel();
+		}
 	}
 
 
diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteProcessor.java b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteProcessor.java
index eb1bbccd8b..45b24f1566 100644
--- a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteProcessor.java
+++ b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteProcessor.java
@@ -111,7 +111,9 @@ public abstract class AbstractListenerWriteProcessor<T> implements Processor<T,
 	 * Listeners can call this method to cancel further writing.
 	 */
 	public void cancel() {
-		this.subscription.cancel();
+		if (this.subscription != null) {
+			this.subscription.cancel();
+		}
 	}