examples/events/__main__.py

@@ -1,5 +1,7 @@
+import json
 import logging
 import time
+from logging import config
 
 import voicemeeterlib
 

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "voicemeeter-api"
-version = "2.4.3"
+version = "2.4.2"
 description = "A Python wrapper for the Voiceemeter API"
 authors = ["onyx-and-iris <code@onyxandiris.online>"]
 license = "MIT"

voicemeeterlib/remote.py

@@ -331,9 +331,8 @@ class Remote(CBindings):
         self.logger.info(f"Profile '{name}' applied!")
 
     def end_thread(self):
-        if self.running:
-            self.logger.debug("events thread shutdown started")
-            self.running = False
+        self.logger.debug("events thread shutdown started")
+        self.running = False
 
     def logout(self) -> None:
         """Logout of the API"""

voicemeeterlib/updater.py

@@ -56,7 +56,12 @@ class Updater(threading.Thread):
 
         Generate _strip_comp, _bus_comp and update level cache if ldirty.
         """
-        while event := self.queue.get():
+        while True:
+            event = self.queue.get()
+            if event is None:
+                self.logger.debug(f"terminating {self.name} thread")
+                break
+
             if event == "pdirty" and self._remote.pdirty:
                 self._remote.subject.notify(event)
             elif event == "mdirty" and self._remote.mdirty:
@@ -68,4 +73,3 @@ class Updater(threading.Thread):
                 self._remote.cache["strip_level"] = self._remote._strip_buf
                 self._remote.cache["bus_level"] = self._remote._bus_buf
                 self._remote.subject.notify(event)
-        self.logger.debug(f"terminating {self.name} thread")