From 51f4a984a5819aeb91ebcd25345b495c87cc02a7 Mon Sep 17 00:00:00 2001 From: dionjansen Date: Sun, 3 Jan 2021 19:14:21 +0100 Subject: [PATCH] cleanup --- src/DotPulsar/Internal/UnackedMessageTracker.cs | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/DotPulsar/Internal/UnackedMessageTracker.cs b/src/DotPulsar/Internal/UnackedMessageTracker.cs index 2b5ef030f..48b4f9b08 100644 --- a/src/DotPulsar/Internal/UnackedMessageTracker.cs +++ b/src/DotPulsar/Internal/UnackedMessageTracker.cs @@ -81,10 +81,8 @@ private IEnumerable CheckUnackedMessages() while (_awaitingAcks.TryPeek(out AwaitingAck awaiting) && awaiting.Elapsed > _ackTimeout) { - // Can I safely use Dequeue now instead of TryDequeue? if (_awaitingAcks.TryDequeue(out awaiting)) { - //If the MessageId is not acknowledged if (!_acked.Contains(awaiting.MessageId)) result.Add(awaiting.MessageId); else