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));