diff --git a/src/main/java/reactor/core/converter/DependencyUtils.java b/src/main/java/reactor/core/converter/DependencyUtils.java index 9be10be3cb..7a5d62a42f 100644 --- a/src/main/java/reactor/core/converter/DependencyUtils.java +++ b/src/main/java/reactor/core/converter/DependencyUtils.java @@ -69,7 +69,7 @@ private DependencyUtils() { } try { - Flux.class.getClassLoader().loadClass("reactor.io.ipc.RemoteFlux"); + Flux.class.getClassLoader().loadClass("reactor.io.ipc.ChannelFlux"); detected |= REACTOR_NET; } catch (ClassNotFoundException ignore) {