From 01b79514dae160a97457e2ae2b158a8bb62feda6 Mon Sep 17 00:00:00 2001
From: Sam Brannen <sbrannen@vmware.com>
Date: Sat, 8 Aug 2020 12:33:26 +0200
Subject: [PATCH] Update ReactiveTypeHandlerTests due to deprecations in
 Reactor

---
 .../mvc/method/annotation/ReactiveTypeHandlerTests.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/spring-webmvc/src/test/java/org/springframework/web/servlet/mvc/method/annotation/ReactiveTypeHandlerTests.java b/spring-webmvc/src/test/java/org/springframework/web/servlet/mvc/method/annotation/ReactiveTypeHandlerTests.java
index aa5ace4614..8b2a4f7fa9 100644
--- a/spring-webmvc/src/test/java/org/springframework/web/servlet/mvc/method/annotation/ReactiveTypeHandlerTests.java
+++ b/spring-webmvc/src/test/java/org/springframework/web/servlet/mvc/method/annotation/ReactiveTypeHandlerTests.java
@@ -109,11 +109,11 @@ public class ReactiveTypeHandlerTests {
 	public void deferredResultSubscriberWithOneValue() throws Exception {
 
 		// Mono
-		MonoProcessor<String> mono = MonoProcessor.create();
+		MonoProcessor<String> mono = MonoProcessor.fromSink(Sinks.one());
 		testDeferredResultSubscriber(mono, Mono.class, forClass(String.class), () -> mono.onNext("foo"), "foo");
 
 		// Mono empty
-		MonoProcessor<String> monoEmpty = MonoProcessor.create();
+		MonoProcessor<String> monoEmpty = MonoProcessor.fromSink(Sinks.one());
 		testDeferredResultSubscriber(monoEmpty, Mono.class, forClass(String.class), monoEmpty::onComplete, null);
 
 		// RxJava Single