A distributed, structured concurrent runtime for Python (and friends)
GNU Affero General Public License v3.0
270
stars
12
forks
source link
`LinkedTaskChannel.subscribe()`, explicit `asyncio` task cancel logging, `test_trioisms.py` #304
Closed
goodboy closed 2 years ago
Basically 2 parts:
to_asyncio.LinkedTaskChannel.subscribe()
which gives task-oriented broadcast functionality semantically equivalent toMsgStream.subscribe()
trio
-side tasks to consumeasyncio
-side task msgs in tandemThis work was originally inspired as part of debugging a case in
piker
's service manager that ended up leading to https://github.com/python-trio/trio/issues/2258.Included is a test that demonstrates the current
trio
behaviour in a newtest_trioisms.py
for tracking such situations in the future.TODO:
LinkedTaskChannel.subscribe()
support