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 0d0378e commit 76fd145Copy full SHA for 76fd145
src/09-built-on-asyncio/the_trio/prod_trio.py
@@ -8,6 +8,14 @@ async def main():
8
t0 = datetime.datetime.now()
9
print(colorama.Fore.WHITE + "App started.", flush=True)
10
11
+ """
12
+ trio.Queue was removed in v0.11.0:
13
+ - Replacing the call to trio.Queue() by trio.open_memory_channel()
14
+ - Using a MemorySendChannel object in generate_data function
15
+ - Using a MemoryReceiveChannel object in process_data function
16
+ - Updating requirements.txt with trio v0.16.0 and trio_asyncio v0.11.0
17
18
+
19
send_channel, receive_channel = trio.open_memory_channel(max_buffer_size=10)
20
21
with trio.move_on_after(5):
0 commit comments