From c48c68c0bcaecca329d15b6559fb22a92581fc80 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Mon, 22 Nov 2021 13:29:11 -0500 Subject: [PATCH] Flip doc strings to my preferred format --- tractor/trionics/_broadcast.py | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/tractor/trionics/_broadcast.py b/tractor/trionics/_broadcast.py index 77ab6d0..6c04895 100644 --- a/tractor/trionics/_broadcast.py +++ b/tractor/trionics/_broadcast.py @@ -47,8 +47,9 @@ class AsyncReceiver( Protocol, 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 @@ -78,7 +79,8 @@ class AsyncReceiver( 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. ''' @@ -86,7 +88,8 @@ class Lagged(trio.TooSlowError): @dataclass class BroadcastState: - '''Common state to all receivers of a broadcast. + ''' + Common state to all receivers of a broadcast. ''' queue: deque @@ -111,7 +114,8 @@ class BroadcastState: 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. Additional consumer tasks can receive all produced values by registering