diff options
| author | Alex Grönholm <alex.gronholm@nextday.fi> | 2021-09-11 21:14:14 +0300 |
|---|---|---|
| committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2021-09-11 21:14:14 +0300 |
| commit | 56afe91d5dc338db3440b2e9ecdea3e522dba30f (patch) | |
| tree | 311380b0d953f09919d7e8c4c0a340507e5d0dc5 /tests/test_datastores.py | |
| parent | 7248a78e7e787b728b083aaa8199eeba3a3f3023 (diff) | |
| download | apscheduler-56afe91d5dc338db3440b2e9ecdea3e522dba30f.tar.gz | |
Implemented a pluggable event broker system
Diffstat (limited to 'tests/test_datastores.py')
| -rw-r--r-- | tests/test_datastores.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tests/test_datastores.py b/tests/test_datastores.py index 52f8349..74db6e7 100644 --- a/tests/test_datastores.py +++ b/tests/test_datastores.py @@ -40,11 +40,11 @@ async def capture_events( events.append(event) if len(events) == limit: limit_event.set() - store.unsubscribe(token) + store.events.unsubscribe(token) events: List[Event] = [] limit_event = anyio.Event() - token = store.subscribe(listener, event_types) + token = store.events.subscribe(listener, event_types) yield events if limit: with anyio.fail_after(3): |