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 <[email protected]>
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));

Reply via email to