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;

Reply via email to