wip

nats-io · Aug 22, 2023 · c03ba31 · c03ba31
1 parent a3099ed
commit c03ba31
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sandbox/Example.JetStream.PullConsumer/Program.cs b/sandbox/Example.JetStream.PullConsumer/Program.cs
@@ -50,7 +50,7 @@ public class State : INatsJSSubState
     private readonly long _expires;
     private readonly long _idle;
     private readonly Timer _timer;
-    private readonly TimeSpan _timeout;
+    private readonly int _timeout;
     private int _pending;
     private volatile INatsJSSub? _sub;
 
@@ -59,7 +59,7 @@ public State(int batch, TimeSpan expires, TimeSpan idle)
         _batch = batch;
         _expires = expires.ToNanos();
         _idle = idle.ToNanos();
-        _timeout = idle * 2;
+        _timeout = (int)(idle * 2).TotalMilliseconds;
         _pending = _batch;
 
         _timer = new Timer(
@@ -113,7 +113,7 @@ public ValueTask ReceivedControlMsgAsync(NatsJSControlMsg controlMsg)
     public void ResetHeartbeatTimer()
     {
         // Console.WriteLine($"RESET HB");
-        _timer.Change(_timeout, _timeout);
+        _timer.Change(_timeout, Timeout.Infinite);
     }
 
     public void ReceivedUserMsg()