aboutsummaryrefslogtreecommitdiffstats
path: root/ttun/pubsub.py
diff options
context:
space:
mode:
authorGravatar Tom van der Lee <tom@vanderlee.io>2022-02-12 11:33:52 +0100
committerGravatar Tom van der Lee <tom@vanderlee.io>2022-02-12 11:33:52 +0100
commit871a85d9343cf49646d13dc455c062efadcb959a (patch)
tree7d36b14b237719901d71d58c88f74b87b875ee61 /ttun/pubsub.py
parent7c48533571e9f9d3731a59433a56cc8d6e008123 (diff)
downloadclient-871a85d9343cf49646d13dc455c062efadcb959a.tar.gz
client-871a85d9343cf49646d13dc455c062efadcb959a.tar.bz2
client-871a85d9343cf49646d13dc455c062efadcb959a.zip
Beatified codev1.3.0
Diffstat (limited to 'ttun/pubsub.py')
-rw-r--r--ttun/pubsub.py8
1 files changed, 5 insertions, 3 deletions
diff --git a/ttun/pubsub.py b/ttun/pubsub.py
index 64dd2b8..0ba964e 100644
--- a/ttun/pubsub.py
+++ b/ttun/pubsub.py
@@ -1,6 +1,8 @@
1import asyncio 1import asyncio
2from contextlib import contextmanager 2from contextlib import contextmanager
3from typing import Any, Generator, Iterator 3from typing import Any
4from typing import Generator
5from typing import Iterator
4 6
5 7
6class PubSub: 8class PubSub:
@@ -8,10 +10,10 @@ class PubSub:
8 10
9 def __init__(self): 11 def __init__(self):
10 self.queues: list[asyncio.Queue] = [] 12 self.queues: list[asyncio.Queue] = []
11 self._history= [] 13 self._history = []
12 14
13 @classmethod 15 @classmethod
14 def instance(cls) -> 'PubSub': 16 def instance(cls) -> "PubSub":
15 if cls._instance == None: 17 if cls._instance == None:
16 cls._instance = cls() 18 cls._instance = cls()
17 return cls._instance 19 return cls._instance