Skip to content

Commit

Permalink
Make Rider happy... VS already happy
Browse files Browse the repository at this point in the history
  • Loading branch information
blankensteiner committed Jun 7, 2024
1 parent 4665061 commit b4a5642
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/DotPulsar/Internal/ConnectionPool.cs
Original file line number Diff line number Diff line change
Expand Up @@ -152,7 +152,7 @@ private async Task<Connection> EstablishNewConnection(PulsarUrl url, Cancellatio
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;
Expand Down

0 comments on commit b4a5642

Please sign in to comment.