Refactored elapsed calc

apache · Jan 3, 2021 · f4725f5 · f4725f5
1 parent 26cd957
commit f4725f5
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/DotPulsar/Internal/UnackedMessageTracker.cs b/src/DotPulsar/Internal/UnackedMessageTracker.cs
@@ -13,15 +13,16 @@
     public readonly struct AwaitingAck
     {
         public MessageId MessageId { get; }
-        public Stopwatch Stopwatch { get; }
+        public long Timestamp { get; }
 
         public AwaitingAck(MessageId messageId)
         {
             MessageId = messageId;
-            Stopwatch = Stopwatch.StartNew();
+            Timestamp = Stopwatch.GetTimestamp();
         }
 
-        public TimeSpan Elapsed => Stopwatch.Elapsed;
+        public TimeSpan Elapsed => TimeSpan.FromTicks(
+            (long) ((Stopwatch.GetTimestamp() - Timestamp) / (double)Stopwatch.Frequency * TimeSpan.TicksPerSecond));
     }
 
     public sealed class UnackedMessageTracker : IUnackedMessageTracker