diff --git a/spring-reactive-modules/spring-5-reactive-3/src/test/java/com/baeldung/cancelflux/CancelFluxUnitTest.java b/spring-reactive-modules/spring-5-reactive-3/src/test/java/com/baeldung/cancelflux/CancelFluxUnitTest.java index 609dbfcf73..e360c2d5e4 100644 --- a/spring-reactive-modules/spring-5-reactive-3/src/test/java/com/baeldung/cancelflux/CancelFluxUnitTest.java +++ b/spring-reactive-modules/spring-5-reactive-3/src/test/java/com/baeldung/cancelflux/CancelFluxUnitTest.java @@ -79,7 +79,7 @@ public class CancelFluxUnitTest { count.incrementAndGet(); }, e -> System.err.println("Error: " + e.getMessage())); - Thread.sleep(5000); + Thread.sleep(4500); System.out.println("Will Dispose The flux Next"); disposable.dispose(); if (disposable.isDisposed()) {