forked from goodboy/tractor
I'm not sure how this ever worked but when a "fake" async gen (i.e. function with special `chan`, `cid` kwargs) is completed we need to signal the end of the stream just like with normal async gens. Also don't fail when trying to remove tasks that were never tracked. Fixes #46 |
||
---|---|---|
.. | ||
testing | ||
__init__.py | ||
_actor.py | ||
_exceptions.py | ||
_forkserver_hackzorz.py | ||
_ipc.py | ||
_portal.py | ||
_state.py | ||
_trionics.py | ||
log.py |