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 2020/09/04 06:37:09 UTC
[pulsar-dotpulsar] branch master updated: Update AsyncQueue.cs (#54)
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 ad86003 Update AsyncQueue.cs (#54)
ad86003 is described below
commit ad860036f94a1f52591342353cc911c76e3e37ff
Author: Pavel Krupets <us...@users.noreply.github.com>
AuthorDate: Thu Sep 3 23:36:59 2020 -0700
Update AsyncQueue.cs (#54)
#53 fixed memory leak in AsyncQueue
Co-authored-by: Pavel Krupets <pk...@mparticle.com>
---
src/DotPulsar/Internal/AsyncQueue.cs | 1 +
1 file changed, 1 insertion(+)
diff --git a/src/DotPulsar/Internal/AsyncQueue.cs b/src/DotPulsar/Internal/AsyncQueue.cs
index 355bd32..6225138 100644
--- a/src/DotPulsar/Internal/AsyncQueue.cs
+++ b/src/DotPulsar/Internal/AsyncQueue.cs
@@ -46,6 +46,7 @@ namespace DotPulsar.Internal
var tcs = _pendingDequeues.First;
_pendingDequeues.RemoveFirst();
tcs.Value.SetResult(item);
+ tcs.Value.Dispose();
}
else
_queue.Enqueue(item);