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

Type the inter-loop chans

remotes/1757153874605917753/main
Tyler Goodlet 2024-12-09 17:37:27 -05:00
parent 9af2a4e739
commit 684253ab11
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tractor/to_asyncio.py
View File

@ -245,14 +245,14 @@ def _run_asyncio_task(
result != orig and
aio_err is None and
# in the ``open_channel_from()`` case we don't
# in the `open_channel_from()` case we don't
# relay through the "return value".
not provide_channels
):
to_trio.send_nowait(result)
finally:
# if the task was spawned using ``open_channel_from()``
# if the task was spawned using `open_channel_from()`
# then we close the channels on exit.
if provide_channels:
# only close the sender side which will relay
@ -500,7 +500,7 @@ async def run_task(
'''
# simple async func
chan = _run_asyncio_task(
chan: LinkedTaskChannel = _run_asyncio_task(
func,
qsize=1,
**kwargs,
@ -530,7 +530,7 @@ async def open_channel_from(
spawned ``asyncio`` task and ``trio``.
'''
chan = _run_asyncio_task(
chan: LinkedTaskChannel = _run_asyncio_task(
target,
qsize=2**8,
provide_channels=True,