From 436a98ec68aa4825c139c6975f1f510e77de186f Mon Sep 17 00:00:00 2001 From: Arjen Poutsma Date: Fri, 22 Jul 2016 15:32:56 +0200 Subject: [PATCH] Polishing --- .../http/server/reactive/AbstractResponseBodyFlushProcessor.java | 1 - 1 file changed, 1 deletion(-) 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(); } }