cleanups

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

@@ -176,7 +176,10 @@ public void ensuresAsyncFusionAndDisposureHasNoDeadlock() {
         unboundedProcessor::dispose,
         Schedulers.elastic());
 
-    assertSubscriber.await(Duration.ofSeconds(50)).values().forEach(ReferenceCountUtil::safeRelease);
+    assertSubscriber
+        .await(Duration.ofSeconds(50))
+        .values()
+        .forEach(ReferenceCountUtil::safeRelease);
 
     allocator.assertHasNoLeaks();
   }