diff --git a/spring-core/src/main/java/org/springframework/core/ReactiveAdapterRegistry.java b/spring-core/src/main/java/org/springframework/core/ReactiveAdapterRegistry.java index 6e077a96fe..4afa633d3a 100644 --- a/spring-core/src/main/java/org/springframework/core/ReactiveAdapterRegistry.java +++ b/spring-core/src/main/java/org/springframework/core/ReactiveAdapterRegistry.java @@ -74,7 +74,8 @@ public class ReactiveAdapterRegistry { this.reactorPresent = reactorRegistered; // RxJava1 - if (ClassUtils.isPresent("rx.Observable", classLoader)) { + if (ClassUtils.isPresent("rx.Observable", classLoader) && + ClassUtils.isPresent("rx.RxReactiveStreams", classLoader)) { new RxJava1Registrar().registerAdapters(this); }