Polish

spring-web/src/main/java/org/springframework/http/server/reactive/AbstractListenerWriteProcessor.java

@@ -163,11 +163,11 @@ public abstract class AbstractListenerWriteProcessor<T> implements Processor<T,
 	}
 
 	/**
-	 * Invoked when an error happens while writing. Defaults to no-op.
+	 * Invoked when an error happens while writing.
-	 * Servlet 3.1 based implementations will receive
+	 * <p>Defaults to no-op. Servlet 3.1 based implementations will receive
-	 * {@link WriteListener#onError(Throwable)} event.
+	 * {@code javax.servlet.WriteListener#onError(Throwable)} event.
 	 */
-	protected void writingFailed(Throwable t) {
+	protected void writingFailed(Throwable ex) {
 	}
 
 

spring-web/src/main/java/org/springframework/http/server/reactive/ServletServerHttpResponse.java

@@ -192,9 +192,10 @@ public class ServletServerHttpResponse extends AbstractListenerServerHttpRespons
 		}
 
 		void handleError(Throwable ex) {
-			if (bodyFlushProcessor != null) {
+			ResponseBodyFlushProcessor flushProcessor = bodyFlushProcessor;
-				bodyFlushProcessor.cancel();
+			if (flushProcessor != null) {
-				bodyFlushProcessor.onError(ex);
+				flushProcessor.cancel();
+				flushProcessor.onError(ex);
 			}
 
 			ResponseBodyProcessor processor = bodyProcessor;
@@ -206,9 +207,10 @@ public class ServletServerHttpResponse extends AbstractListenerServerHttpRespons
 
 		@Override
 		public void onComplete(AsyncEvent event) {
-			if (bodyFlushProcessor != null) {
+			ResponseBodyFlushProcessor flushProcessor = bodyFlushProcessor;
-				bodyFlushProcessor.cancel();
+			if (flushProcessor != null) {
-				bodyFlushProcessor.onComplete();
+				flushProcessor.cancel();
+				flushProcessor.onComplete();
 			}
 
 			ResponseBodyProcessor processor = bodyProcessor;

spring-web/src/main/java/org/springframework/http/server/reactive/UndertowServerHttpResponse.java

@@ -231,9 +231,9 @@ public class UndertowServerHttpResponse extends AbstractListenerServerHttpRespon
 		}
 
 		@Override
-		protected void writingFailed(Throwable t) {
+		protected void writingFailed(Throwable ex) {
 			cancel();
-			onError(t);
+			onError(ex);
 		}
 	}