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 | ||