danvics/ytptube
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

minor logs update

Browse source
This commit is contained in:
arabcoders 2025-06-23 01:07:50 +03:00
parent f6e3c94432
commit 74699680ea
2 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app/library/DownloadQueue.py
View file

@ -117,7 +117,7 @@ class DownloadQueue(metaclass=Singleton):
"""
self._notify.subscribe(
Events.STARTED, lambda _, __: self.initialize(), f"{__class__.__name__}.{__class__.__name__}.initialize"
Events.STARTED, lambda _, __: self.initialize(), f"{__class__.__name__}.{__class__.initialize.__name__}"
)
Scheduler.get_instance().add(

7
app/library/Events.py
View file

@ -325,6 +325,8 @@ class EventBus(metaclass=Singleton):
self._listeners[e][name] = EventListener(name, callback)
LOG.debug(f"'{name}' subscribed to '{event}'.")
return self
def unsubscribe(self, event: str | list | tuple, name: str) -> "EventBus":
@ -342,10 +344,15 @@ class EventBus(metaclass=Singleton):
if isinstance(event, str):
event = [event]
events = []
for e in event:
if e in self._listeners and name in self._listeners[e]:
events.append(e)
del self._listeners[e][name]
if len(events) > 0:
LOG.debug(f"'{name}' unsubscribed from '{events}'.")
return self
def sync_emit(self, event: str, data: Any, loop=None, wait: bool = True, **kwargs):