Allow to use bounded queues
1 files changed, 1 insertions(+), 1 deletions(-) M aio_mpv_ipc/_client.py
M aio_mpv_ipc/_client.py => aio_mpv_ipc/_client.py +1 -1
@@ 163,7 163,7 @@ class MpvClient: # This is an event notification, notify subscribers (if any). if event_name in self._event_subscribers: for queue in self._event_subscribers[event_name]: queue.put_nowait(response) await queue.put(response) else: status = response.get("error") is_error = status and status != "success"