cleanups

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

@@ -176,7 +176,6 @@ void drainFused(Subscriber<? super T> a) {
 
         Throwable ex = error;
         if (ex != null) {
-          System.out.println("Send Error");
           a.onError(ex);
         } else {
           a.onComplete();

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

@@ -149,7 +149,7 @@ public void ensureUnboundedProcessorDisposesQueueProperly(boolean withFusionEnab
       name =
           "Ensures that racing between onNext + dispose | downstream async drain) should not cause any issues and leaks",
       value = 100000)
-  @Timeout(10)
+  @Timeout(60)
   public void ensuresAsyncFusionAndDisposureHasNoDeadlock() {
     final LeaksTrackingByteBufAllocator allocator =
         LeaksTrackingByteBufAllocator.instrument(ByteBufAllocator.DEFAULT);
@@ -176,7 +176,7 @@ public void ensuresAsyncFusionAndDisposureHasNoDeadlock() {
         unboundedProcessor::dispose,
         Schedulers.elastic());
 
-    assertSubscriber.await(Duration.ofSeconds(5)).values().forEach(ReferenceCountUtil::safeRelease);
+    assertSubscriber.await(Duration.ofSeconds(50)).values().forEach(ReferenceCountUtil::safeRelease);
 
     allocator.assertHasNoLeaks();
   }