diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractResponseBodyFlushProcessor.java b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractResponseBodyFlushProcessor.java
index ab2dc0a3de..71adf24dd1 100644
--- a/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractResponseBodyFlushProcessor.java
+++ b/spring-web/src/main/java/org/springframework/http/server/reactive/AbstractResponseBodyFlushProcessor.java
@@ -151,7 +151,6 @@ abstract class AbstractResponseBodyFlushProcessor
 			public void writeComplete(AbstractResponseBodyFlushProcessor processor) {
 				if (processor.subscriberCompleted) {
 					if (processor.changeState(this, COMPLETED)) {
-						processor.subscriberCompleted = true;
 						processor.publisherDelegate.publishComplete();
 					}
 				}