AudioController blocking: block only on incoming queue

This commit is contained in:
norohind 2022-11-13 20:38:42 +03:00
parent 17d3ec3f70
commit 80b0ae5175
Signed by: norohind
GPG Key ID: 01C3BECC26FB59E1

View File

@ -130,7 +130,7 @@ class AudioController:
def _state_change_tick(self):
try:
msg = self._state_change_q.get(timeout=0.1)
msg = self._state_change_q.get_nowait()
logger.trace(f'New state message {msg}')
except Empty:
@ -231,7 +231,7 @@ class AudioController:
def _inbound_q_tick(self):
try:
event: Events.ClientToServerEvent = self.inbound_q.get_nowait()
event: Events.ClientToServerEvent = self.inbound_q.get(timeout=0.1)
except queue.Empty:
return