You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by bl...@apache.org on 2023/08/25 11:29:53 UTC

[pulsar-dotpulsar] branch master updated: Fix warning

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 564eb9b  Fix warning
564eb9b is described below

commit 564eb9bd9efc8ea679bb1e312370c4e803b4dd17
Author: Daniel Blankensteiner <db...@vmail.dk>
AuthorDate: Fri Aug 25 13:29:44 2023 +0200

    Fix warning
---
 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 6631f5f..939eef7 100644
--- a/src/DotPulsar/Internal/ConnectionPool.cs
+++ b/src/DotPulsar/Internal/ConnectionPool.cs
@@ -160,7 +160,7 @@ public sealed class ConnectionPool : IConnectionPool
     {
         var stream = await _connector.Connect(url.Physical).ConfigureAwait(false);
         var connection = new Connection(new PulsarStream(stream), _keepAliveInterval, _authentication);
-        connection.WaitForInactive().ContinueWith(async t => { await DisposeConnection(url); }, cancellationToken);
+        _ = connection.WaitForInactive().ContinueWith(async _ => await DisposeConnection(url).ConfigureAwait(false), cancellationToken);
         DotPulsarMeter.ConnectionCreated();
         _connections[url] = connection;
         _ = connection.ProcessIncomingFrames(_cancellationTokenSource.Token).ContinueWith(t => DisposeConnection(url));