commit ad860036f94a1f52591342353cc911c76e3e37ff
author Pavel Krupets <usaguerrilla@users.noreply.github.com> Thu Sep 03 23:36:59 2020 -0700
committer GitHub <noreply@github.com> Fri Sep 04 08:36:59 2020 +0200
tree 4ee1a194ba0ff4b833ca78a8851a4b38c63534ac
parent 7b1eaf62ddbd432367bd6601a3593df7c33d7bf6

Update AsyncQueue.cs (#54)

#53 fixed memory leak in AsyncQueue

Co-authored-by: Pavel Krupets <pkrupets@mparticle.com>

src/DotPulsar/Internal/AsyncQueue.cs

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 @@
                     var tcs = _pendingDequeues.First;
                     _pendingDequeues.RemoveFirst();
                     tcs.Value.SetResult(item);
+                    tcs.Value.Dispose();
                 }
                 else
                     _queue.Enqueue(item);