examples/events/__main__.py

@@ -17,12 +17,6 @@ class Observer:
         print(f"Registered events: {self._client.callback.get()}")
         self.running = True
 
-    def __enter__(self):
-        return self
-
-    def __exit__(self, exc_type, exc_value, exc_traceback):
-        self._client.disconnect()
-
     def on_current_program_scene_changed(self, data):
         """The current program scene has changed."""
         print(f"Switched to scene {data.scene_name}")
@@ -37,11 +31,13 @@ class Observer:
 
     def on_exit_started(self, _):
         """OBS has begun the shutdown process."""
-        print("OBS closing!")
+        print(f"OBS closing!")
+        self._client.unsubscribe()
         self.running = False
 
 
 if __name__ == "__main__":
-    with Observer() as observer:
+    observer = Observer()
+
     while observer.running:
         time.sleep(0.1)

examples/hotkeys/__main__.py

@@ -1,7 +1,6 @@
 import inspect
 
 import keyboard
-
 import obsws_python as obs
 
 
@@ -11,12 +10,6 @@ class Observer:
         self._client.callback.register(self.on_current_program_scene_changed)
         print(f"Registered events: {self._client.callback.get()}")
 
-    def __enter__(self):
-        return self
-
-    def __exit__(self, exc_type, exc_value, exc_traceback):
-        self._client.disconnect()
-
     @property
     def event_identifier(self):
         return inspect.stack()[1].function
@@ -38,8 +31,9 @@ def set_scene(scene, *args):
 
 
 if __name__ == "__main__":
-    with obs.ReqClient() as req_client:
+    req_client = obs.ReqClient()
-        with Observer() as observer:
+    observer = Observer()
+
     keyboard.add_hotkey("0", version)
     keyboard.add_hotkey("1", set_scene, args=("START",))
     keyboard.add_hotkey("2", set_scene, args=("BRB",))

examples/levels/__main__.py

@@ -9,8 +9,6 @@ LEVELTYPE = IntEnum(
     start=0,
 )
 
-DEVICE = "Desktop Audio"
-
 
 def on_input_mute_state_changed(data):
     """An input's mute state has changed."""
@@ -34,14 +32,15 @@ def on_input_volume_meters(data):
 
 
 def main():
-    with obs.EventClient(
+    client = obs.EventClient(subs=(obs.Subs.LOW_VOLUME | obs.Subs.INPUTVOLUMEMETERS))
-        subs=(obs.Subs.LOW_VOLUME | obs.Subs.INPUTVOLUMEMETERS)
-    ) as client:
     client.callback.register([on_input_volume_meters, on_input_mute_state_changed])
 
-        while _ := input("Press <Enter> to exit\n"):
+    while cmd := input("<Enter> to exit>\n"):
-            pass
+        if not cmd:
+            break
 
 
 if __name__ == "__main__":
+    DEVICE = "Desktop Audio"
+
     main()

obsws_python/events.py

@@ -1,8 +1,9 @@
 import json
 import logging
-import threading
+import time
+from threading import Thread
 
-from websocket import WebSocketConnectionClosedException, WebSocketTimeoutException
+from websocket import WebSocketTimeoutException
 
 from .baseclient import ObsClient
 from .callback import Callback
@@ -19,6 +20,8 @@ logger = logging.getLogger(__name__)
 
 
 class EventClient:
+    DELAY = 0.001
+
     def __init__(self, **kwargs):
         self.logger = logger.getChild(self.__class__.__name__)
         defaultkwargs = {"subs": Subs.LOW_VOLUME}
@@ -35,12 +38,6 @@ class EventClient:
         self.callback = Callback()
         self.subscribe()
 
-    def __enter__(self):
-        return self
-
-    def __exit__(self, exc_type, exc_value, exc_traceback):
-        self.disconnect()
-
     def __repr__(self):
         return type(
             self
@@ -52,40 +49,33 @@ class EventClient:
         return type(self).__name__
 
     def subscribe(self):
-        self.base_client.ws.settimeout(None)
+        worker = Thread(target=self.trigger, daemon=True)
-        stop_event = threading.Event()
+        worker.start()
-        self.worker = threading.Thread(
-            target=self.trigger, daemon=True, args=(stop_event,)
-        )
-        self.worker.start()
 
-    def trigger(self, stop_event):
+    def trigger(self):
         """
         Continuously listen for events.
 
         Triggers a callback on event received.
         """
-        while not stop_event.is_set():
+        self.running = True
+        while self.running:
             try:
-                if response := self.base_client.ws.recv():
+                event = json.loads(self.base_client.ws.recv())
-                    event = json.loads(response)
+            except WebSocketTimeoutException as e:
+                self.logger.exception(f"{type(e).__name__}: {e}")
+                raise OBSSDKTimeoutError("Timeout while waiting for event") from e
             self.logger.debug(f"Event received {event}")
             type_, data = (
                 event["d"].get("eventType"),
                 event["d"].get("eventData"),
             )
             self.callback.trigger(type_, data if data else {})
-            except WebSocketTimeoutException as e:
+            time.sleep(self.DELAY)
-                self.logger.exception(f"{type(e).__name__}: {e}")
-                raise OBSSDKTimeoutError("Timeout while waiting for event") from e
-            except (WebSocketConnectionClosedException, OSError) as e:
-                self.logger.debug(f"{type(e).__name__} terminating the event thread")
-                stop_event.set()
-
-    def disconnect(self):
-        """stop listening for events"""
 
+    def unsubscribe(self):
+        """
+        stop listening for events
+        """
+        self.running = False
         self.base_client.ws.close()
-        self.worker.join()
-
-    unsubscribe = disconnect

obsws_python/reqs.py

@@ -31,7 +31,7 @@ class ReqClient:
         return self
 
     def __exit__(self, exc_type, exc_value, exc_traceback):
-        self.disconnect()
+        self.base_client.ws.close()
 
     def __repr__(self):
         return type(
@@ -43,9 +43,6 @@ class ReqClient:
     def __str__(self):
         return type(self).__name__
 
-    def disconnect(self):
-        self.base_client.ws.close()
-
     def send(self, param, data=None, raw=False):
         try:
             response = self.base_client.req(param, data)

obsws_python/version.py

@@ -1 +1 @@
-version = "1.7.0"
+version = "1.6.2"