adds logs

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

Author: OlegDokuka

rsocket-core/src/main/java/io/rsocket/internal/UnboundedProcessor.java

@@ -440,8 +440,11 @@ public void dispose() {
 
         if (a != null && once) {
           try {
+            System.out.println("sending error");
             a.onError(error);
           } catch (Throwable ignored) {
+            System.out.println("bubbled");
+            ignored.printStackTrace();
           }
         }
 

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

@@ -147,7 +147,7 @@ public void ensureUnboundedProcessorDisposesQueueProperly(boolean withFusionEnab
 
   @RepeatedTest(
       name =
-          "Ensures that racing between onNext + dispose | downstream async drain) should not cause any issues and leaks",
+          "Ensures that racing between onNext + dispose | downstream async drain should not cause any issues and leaks",
       value = 100000)
   @Timeout(60)
   public void ensuresAsyncFusionAndDisposureHasNoDeadlock() {