Update CancelFluxUnitTest.java (#13893)
This commit is contained in:
parent
5b6d81ff3d
commit
321e1d3fcc
|
@ -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()) {
|
||||
|
|
Loading…
Reference in New Issue