Tyler Goodlet 3deb1b91e6 Wake all broadcast consumers on EOC ... Without this wakeup you can have tasks which re-enter `.receive()` and get stuck waiting on the wakeup event indefinitely. Whenever a ``trio.EndOfChannel`` arrives we want to make sure all consumers at least know about it and don't block. This previous behaviour was basically a bug. Add some state flags for tracking if the broadcaster was either cancelled or terminated via EOC mostly for testing and debugging purposes though this info might be useful if we decide to offer a `.statistics()` like API in the future.		2021-12-16 16:16:14 -05:00
..
__init__.py	Re-license code base for distribution under AGPL	2021-12-14 23:33:27 -05:00
_broadcast.py	Wake all broadcast consumers on EOC	2021-12-16 16:16:14 -05:00
_mngrs.py	Re-license code base for distribution under AGPL	2021-12-14 23:33:27 -05:00