This is an automated email from the ASF dual-hosted git repository.
blankensteiner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-dotpulsar.git
The following commit(s) were added to refs/heads/master by this push:
new b4a5642 Make Rider happy... VS already happy
b4a5642 is described below
commit b4a5642fbb14d642674d4a3bf7720e7ce16e197a
Author: Daniel Blankensteiner <[email protected]>
AuthorDate: Fri Jun 7 11:08:44 2024 +0200
Make Rider happy... VS already happy
---
src/DotPulsar/Internal/ConnectionPool.cs | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/DotPulsar/Internal/ConnectionPool.cs
b/src/DotPulsar/Internal/ConnectionPool.cs
index 6cb1481..8d794c4 100644
--- a/src/DotPulsar/Internal/ConnectionPool.cs
+++ b/src/DotPulsar/Internal/ConnectionPool.cs
@@ -152,7 +152,7 @@ public sealed class ConnectionPool : IConnectionPool
commandConnect = WithProxyToBroker(commandConnect, url.Logical);
var connection = Connection.Connect(new PulsarStream(stream),
_authentication, _keepAliveInterval, _closeInactiveConnectionsInterval);
- _ = connection.OnStateChangeFrom(ConnectionState.Connected,
CancellationToken.None).AsTask().ContinueWith(t => DisposeConnection(url,
connection));
+ _ = connection.OnStateChangeFrom(ConnectionState.Connected,
CancellationToken.None).AsTask().ContinueWith(t => DisposeConnection(url,
connection), CancellationToken.None);
var response = await connection.Send(commandConnect,
cancellationToken).ConfigureAwait(false);
response.Expect(BaseCommand.Type.Connected);
_connections[url] = connection;