jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

Support no arg to `Context.started()` like trio

wip_fix_asyncio_gen_streaming
Tyler Goodlet 2021-05-25 09:19:07 -04:00
parent df420fcafc
commit 98a69f06b4
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tractor/_streaming.py
View File

@ -339,7 +339,7 @@ class Context:
if self._portal: if self._portal:
self._portal._streams.remove(rchan) self._portal._streams.remove(rchan)
async def started(self, value: Any) -> None: async def started(self, value: Optional[Any] = None) -> None:
if self._portal: if self._portal:
raise RuntimeError( raise RuntimeError(