From e4588628491889369119d73e801bdd7481ae13d3 Mon Sep 17 00:00:00 2001
From: Arjen Poutsma <apoutsma@pivotal.io>
Date: Fri, 7 Jul 2017 15:24:15 +0200
Subject: [PATCH] Reflect recent Reactor changes

---
 .../http/server/reactive/ChannelSendOperator.java           | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/ChannelSendOperator.java b/spring-web/src/main/java/org/springframework/http/server/reactive/ChannelSendOperator.java
index 8f5e5f555d..45e8b8c003 100644
--- a/spring-web/src/main/java/org/springframework/http/server/reactive/ChannelSendOperator.java
+++ b/spring-web/src/main/java/org/springframework/http/server/reactive/ChannelSendOperator.java
@@ -21,11 +21,11 @@ import java.util.function.Function;
 import org.reactivestreams.Publisher;
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
+import reactor.core.CoreSubscriber;
 import reactor.core.Scannable;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.core.publisher.Operators;
-import reactor.util.context.Context;
 
 import org.springframework.lang.Nullable;
 import org.springframework.util.Assert;
@@ -69,8 +69,8 @@ public class ChannelSendOperator<T> extends Mono<Void> implements Scannable {
 	}
 
 	@Override
-	public void subscribe(Subscriber<? super Void> s, Context ctx) {
-		this.source.subscribe(new WriteWithBarrier(s), ctx);
+	public void subscribe(CoreSubscriber<? super Void> actual) {
+		this.source.subscribe(new WriteWithBarrier(actual));
 	}