jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

Flip doc strings to my preferred format

infect_asyncio
Tyler Goodlet 2021-11-22 13:29:11 -05:00
parent ad2567dd73
commit c48c68c0bc
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tractor/trionics/_broadcast.py
View File

@ -47,8 +47,9 @@ class AsyncReceiver(
Protocol, Protocol,
Generic[ReceiveType], Generic[ReceiveType],
): ):
'''An async receivable duck-type that quacks much like trio's '''
``trio.abc.ReceieveChannel``. An async receivable duck-type that quacks much like trio's
``trio.abc.ReceiveChannel``.
''' '''
@abstractmethod @abstractmethod
@ -78,7 +79,8 @@ class AsyncReceiver(
class Lagged(trio.TooSlowError): class Lagged(trio.TooSlowError):
'''Subscribed consumer task was too slow and was overrun '''
Subscribed consumer task was too slow and was overrun
by the fastest consumer-producer pair. by the fastest consumer-producer pair.
''' '''
@ -86,7 +88,8 @@ class Lagged(trio.TooSlowError):
@dataclass @dataclass
class BroadcastState: class BroadcastState:
'''Common state to all receivers of a broadcast. '''
Common state to all receivers of a broadcast.
''' '''
queue: deque queue: deque
@ -111,7 +114,8 @@ class BroadcastState:
class BroadcastReceiver(ReceiveChannel): class BroadcastReceiver(ReceiveChannel):
'''A memory receive channel broadcaster which is non-lossy for the '''
A memory receive channel broadcaster which is non-lossy for the
fastest consumer. fastest consumer.
Additional consumer tasks can receive all produced values by registering Additional consumer tasks can receive all produced values by registering