diff --git a/spring-boot-admin-server/src/test/java/de/codecentric/boot/admin/server/config/AdminServerNotifierAutoConfigurationTest.java b/spring-boot-admin-server/src/test/java/de/codecentric/boot/admin/server/config/AdminServerNotifierAutoConfigurationTest.java index cb6b97c7b27..c99e907d3db 100644 --- a/spring-boot-admin-server/src/test/java/de/codecentric/boot/admin/server/config/AdminServerNotifierAutoConfigurationTest.java +++ b/spring-boot-admin-server/src/test/java/de/codecentric/boot/admin/server/config/AdminServerNotifierAutoConfigurationTest.java @@ -209,7 +209,7 @@ private static class TestNotifier implements Notifier { private TestNotifier() { UnicastProcessor unicastProcessor = UnicastProcessor.create(); - this.publishedFlux = unicastProcessor.publish().autoConnect(0); + this.publishedFlux = unicastProcessor; this.sink = unicastProcessor.sink(); }