Added count locks to termintation callback in GroupedDataSubscriber

ritchiecarroll · ritchiecarroll · commit 2b634f80bc9e · 2024-07-30T18:06:12.000-05:00
diff --git a/examples/groupeddatasubscribe/main.py b/examples/groupeddatasubscribe/main.py
@@ -308,7 +308,12 @@ def _connection_terminated(self):
         self._lastmessage = 0.0
 
         # Reset grouped data on disconnect
-        self._downsampled_count = 0
+        with self._downsampled_count_lock:
+            self._downsampled_count = 0
+
+        # Reset process missed count on disconnect
+        with self._process_missed_count_lock:
+            self._process_missed_count += 1
 
 
 def main():
