fixes

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

Author: OlegDokuka

rsocket-test/src/main/java/io/rsocket/test/TransportTest.java

@@ -642,7 +642,9 @@ public String expectedPayloadMetadata() {
     }
 
     public void awaitClosed() {
-      Mono.whenDelayError(server.onClose().log("server"), client.onClose().log("client"))
+      Mono.whenDelayError(
+              server.onClose().delaySubscription(Duration.ofSeconds(1)).log("server"),
+              client.onClose().log("client"))
           .block(Duration.ofMinutes(1));
     }