Change event_queue.get() to be a blocking call, meaning that any new events in the queue will instantly reflect their requested changes rather than waiting for 1-2 seconds due to the time.sleep()

Author: SteveMicroNova

streams/volume_synchronizer.py

@@ -135,7 +135,7 @@ def on_child_event(self, event_type):
   def watcher_loop(self):
     while True:
       try:
-        event = self.event_queue.get(timeout=2)
+        event = self.event_queue.get()
         if event == "stream_volume_changed":
           self.vol_set_point = self.amplipi.set_vol(self.stream.volume, self.vol_set_point)
         elif event == "amplipi_volume_changed":
@@ -148,4 +148,3 @@ def watcher_loop(self):
       except Exception as e:
         self.logger.exception(f"Exception: {e}")
         continue
-      sleep(1)