Merge branch 'refs/heads/master' into audit-logging

scalecube · Dec 4, 2024 · 326d35d · 326d35d
2 parents fca79bf + 9135d84
commit 326d35d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketClientTransport.java b/...rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketClientTransport.java
@@ -70,7 +70,7 @@ public ClientChannel create(ServiceReference serviceReference) {
             key ->
                 getCredentials(serviceReference)
                     .flatMap(creds -> connect(key, creds, monoMap))
-                    .cache()
+                    .cacheInvalidateIf(RSocket::isDisposed)
                     .doOnError(ex -> monoMap.remove(key)));
     return new RSocketClientChannel(mono, new ServiceMessageCodec(headersCodec, dataCodecs));
   }