From 927ade3502621178546c3c767b80c2016e176542 Mon Sep 17 00:00:00 2001 From: Tai Sakuma Date: Wed, 20 Jul 2022 19:26:31 -0400 Subject: [PATCH] clean code --- nextline/utils/pubsub/broker.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/nextline/utils/pubsub/broker.py b/nextline/utils/pubsub/broker.py index b5999aa6..4bbebc8b 100644 --- a/nextline/utils/pubsub/broker.py +++ b/nextline/utils/pubsub/broker.py @@ -12,10 +12,11 @@ class PubSub(Generic[_KT, _VT]): """Asynchronous message broker of the publish-subscribe pattern""" - def __init__(self, *args, **kwargs): - self._queue: DefaultDict[_KT, PubSubItem[_VT]] = defaultdict( - PubSubItem - ) + def __init__(self): + self._queue: DefaultDict[ + _KT, + PubSubItem[_VT], + ] = defaultdict(PubSubItem) def subscribe( self, key: _KT, last: Optional[bool] = True