diff --git a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/UndertowHttpHandlerAdapter.java b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/UndertowHttpHandlerAdapter.java index 03e109575d6..c01e34d0d1a 100644 --- a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/UndertowHttpHandlerAdapter.java +++ b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/UndertowHttpHandlerAdapter.java @@ -131,7 +131,7 @@ public class UndertowHttpHandlerAdapter implements io.undertow.server.HttpHandle @Override public void subscribe(Subscriber subscriber) { if (subscriber == null) { - throw Exceptions.spec_2_13_exception(); + throw Exceptions.argumentIsNullException(); } if (this.subscriber != null) { subscriber.onError(new IllegalStateException("Only one subscriber allowed")); diff --git a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java index 786fabaa086..99c8c0523e4 100644 --- a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java +++ b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java @@ -27,6 +27,7 @@ import org.junit.runners.Parameterized; import reactor.core.publisher.Mono; import reactor.core.publisher.ProcessorGroup; import reactor.core.publisher.Processors; +import reactor.core.timer.Timer; import reactor.rx.Stream; import org.springframework.core.io.buffer.DataBufferAllocator;