Propagate the cancel signal to the downstream

Author: violetagg

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

@@ -337,6 +337,8 @@ private class WriteCompletionBarrier implements CoreSubscriber<Void>, Subscripti
 
 		private final WriteBarrier writeBarrier;
 
+		private Subscription subscription;
+
 
 		public WriteCompletionBarrier(CoreSubscriber<? super Void> subscriber, WriteBarrier writeBarrier) {
 			this.completionSubscriber = subscriber;
@@ -356,6 +358,7 @@ public void connect() {
 
 		@Override
 		public void onSubscribe(Subscription subscription) {
+			this.subscription = subscription;
 			subscription.request(Long.MAX_VALUE);
 		}
 
@@ -387,6 +390,10 @@ public void request(long n) {
 		@Override
 		public void cancel() {
 			this.writeBarrier.cancel();
+			Subscription subscription = this.subscription;
+			if (subscription != null) {
+				subscription.cancel();
+			}
 		}
 	}