fixes

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

Author: OlegDokuka

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

@@ -618,7 +618,7 @@ public TransportPair(
     @Override
     public void dispose() {
       client.dispose();
-      server.dispose();
+      //      server.dispose();
     }
 
     RSocket getClient() {
@@ -634,9 +634,12 @@ public String expectedPayloadMetadata() {
     }
 
     public void awaitClosed() {
-      Mono.whenDelayError(
-              server.onClose().delaySubscription(Duration.ofSeconds(1)).log("server"),
-              client.onClose().log("client"))
+      client
+          .onClose()
+          .log("client")
+          .onErrorResume(t -> Mono.empty())
+          .then(Mono.fromRunnable(server::dispose))
+          .then(server.onClose().delaySubscription(Duration.ofSeconds(1)).log("server"))
           .block(Duration.ofMinutes(1));
     }