goodboy
/
tractor
1
0
Fork 2
Code Issues 5 Pull Requests 7 Packages Projects Releases Wiki Activity

Alias to `@acm` in broadcaster mod

oco_supervisor_prototype
Tyler Goodlet 2023-05-17 15:27:29 -04:00 committed by goodboy
parent cb0d1a87f5
commit 5860e02efd
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tractor/trionics/_broadcast.py
View File

@ -22,7 +22,7 @@ https://docs.rs/tokio/1.11.0/tokio/sync/broadcast/index.html
from __future__ import annotations from __future__ import annotations
from abc import abstractmethod from abc import abstractmethod
from collections import deque from collections import deque
from contextlib import asynccontextmanager from contextlib import asynccontextmanager as acm
from functools import partial from functools import partial
from operator import ne from operator import ne
from typing import ( from typing import (
@ -398,7 +398,7 @@ class BroadcastReceiver(ReceiveChannel):
return await self._receive_from_underlying(key, state) return await self._receive_from_underlying(key, state)
@asynccontextmanager @acm
async def subscribe( async def subscribe(
self, self,
raise_on_lag: bool = True, raise_on_lag: bool = True,