We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1087730 commit c1a746dCopy full SHA for c1a746d
src/mario/traversals.py
@@ -111,7 +111,7 @@ def _threaded_sync_apply(
111
This function is run in a thread.
112
113
"""
114
- # iterator = _pull_values_from_async_iterator(in_trio, ait, send_to_trio)
+
115
try:
116
for x in iterator:
117
in_trio.run(send_to_trio.send, x)
@@ -126,8 +126,6 @@ async def sync_apply(
126
thread.
127
128
in_trio = trio.BlockingTrioPortal()
129
- # send_to_trio: trio.abc.SendChannel
130
- # receive_from_thread: trio.abc.ReceiveChannel
131
send_to_trio, receive_from_thread = trio.open_memory_channel[t.Tuple[T, t.Any]](0)
132
133
async with trio.open_nursery() as n:
0 commit comments