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