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

artem-v · artem-v · commit 326d35d285bc · 2024-12-04T20:16:21.000+02:00
diff --git a/services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketClientTransport.java b/services-transport-parent/services-transport-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));
   }

Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,7 @@ public ClientChannel create(ServiceReference serviceReference) {`
`70`	`70`	`key ->`
`71`	`71`	`getCredentials(serviceReference)`
`72`	`72`	`.flatMap(creds -> connect(key, creds, monoMap))`
`73`		`- .cache()`
	`73`	`+ .cacheInvalidateIf(RSocket::isDisposed)`
`74`	`74`	`.doOnError(ex -> monoMap.remove(key)));`
`75`	`75`	`return new RSocketClientChannel(mono, new ServiceMessageCodec(headersCodec, dataCodecs));`
`76`	`76`	`}`