Merge pull request #229 from goodboy/live_on_air_from_tokio

`tokio`-style broadcast channels
goodboy · Sep 3, 2021 · 3f1bc37 · 3f1bc37
2 parents 87ce6c8 + 1137a9e
commit 3f1bc37
Show file tree

Hide file tree

Showing 6 changed files with 842 additions and 14 deletions.
diff --git a/newsfragments/229.feature.rst b/newsfragments/229.feature.rst
@@ -0,0 +1,12 @@
+Add `tokio-style broadcast channels
+<https://docs.rs/tokio/1.11.0/tokio/sync/broadcast/index.html>`_ as
+a solution for `#204 <https://github.com/goodboy/tractor/pull/204>`_ and
+discussed thoroughly in `trio/#987
+<https://github.com/python-trio/trio/issues/987>`_.
+
+This gives us local task broadcast functionality using a new
+``BroadcastReceiver`` type which can wrap ``trio.ReceiveChannel``  and
+provide fan-out copies of a stream of data to every subscribed consumer.
+We use this new machinery to provide a ``ReceiveMsgStream.subscribe()``
+async context manager which can be used by actor-local concumers tasks
+to easily pull from a shared and dynamic IPC stream.