imrpoves test

Signed-off-by: Oleh Dokuka <[email protected]>
Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

rsocket-core/src/test/java/io/rsocket/internal/UnboundedProcessorTest.java

@@ -146,10 +146,10 @@ public void ensureUnboundedProcessorDisposesQueueProperly(boolean withFusionEnab
 
   @RepeatedTest(
       name =
-          "Ensures that racing between onNext | dispose | cancel | request(n) will not cause any issues and leaks in async backFused mode",
+          "Ensures that racing between onNext + dispose | downstream async drain) should not cause any issues and leaks",
       value = 100000)
   @Timeout(10)
-  public void ensureUnboundedProcessorDisposesQueueProperlyAsyncMode() {
+  public void ensuresAsyncFusionAndDisposureHasNoDeadlocl() {
     final LeaksTrackingByteBufAllocator allocator =
         LeaksTrackingByteBufAllocator.instrument(ByteBufAllocator.DEFAULT);
     final UnboundedProcessor<ByteBuf> unboundedProcessor = new UnboundedProcessor<>();
@@ -175,7 +175,7 @@ public void ensureUnboundedProcessorDisposesQueueProperlyAsyncMode() {
         unboundedProcessor::dispose,
         Schedulers.elastic());
 
-    assertSubscriber.values().forEach(ReferenceCountUtil::safeRelease);
+    assertSubscriber.await().values().forEach(ReferenceCountUtil::safeRelease);
 
     allocator.assertHasNoLeaks();
   }