diff options
| author | 2022-02-12 11:33:52 +0100 | |
|---|---|---|
| committer | 2022-02-12 11:33:52 +0100 | |
| commit | 871a85d9343cf49646d13dc455c062efadcb959a (patch) | |
| tree | 7d36b14b237719901d71d58c88f74b87b875ee61 /ttun/pubsub.py | |
| parent | 7c48533571e9f9d3731a59433a56cc8d6e008123 (diff) | |
| download | client-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.py | 8 |
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 @@ | |||
| 1 | import asyncio | 1 | import asyncio |
| 2 | from contextlib import contextmanager | 2 | from contextlib import contextmanager |
| 3 | from typing import Any, Generator, Iterator | 3 | from typing import Any |
| 4 | from typing import Generator | ||
| 5 | from typing import Iterator | ||
| 4 | 6 | ||
| 5 | 7 | ||
| 6 | class PubSub: | 8 | class 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 |
