fix: cache not expired after RSocket disposed (#866)

scalecube · Dec 4, 2024 · 9135d84 · 9135d84
1 parent a4d844d
commit 9135d84
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));
   }