From 800a173aa686733831112c418e9a8f1a6df6ba99 Mon Sep 17 00:00:00 2001 From: Nocturn9x Date: Sun, 27 Feb 2022 13:40:26 +0100 Subject: [PATCH] Minor change to task_ipc test --- tests/task_ipc.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/tests/task_ipc.py b/tests/task_ipc.py index 79617df..87faf48 100644 --- a/tests/task_ipc.py +++ b/tests/task_ipc.py @@ -15,19 +15,19 @@ async def task(c: giambio.MemoryChannel, name: str): await giambio.sleep(1) -async def main(channel: giambio.MemoryChannel): - print("[main] Spawning workers") - async with giambio.skip_after(5) as pool: +async def main(channel: giambio.MemoryChannel, delay: int): + print(f"[main] Spawning workers, exiting in {delay} seconds") + async with giambio.skip_after(delay) as pool: await pool.spawn(task, channel, "one") await pool.spawn(task, channel, "two") await pool.spawn(task, channel, "three") await channel.close() print(f"[main] Operation complete, channel closed") if await channel.pending(): - print(f"[main] Channel has {len(channel.buffer)} leftover packets of data, clearing it") + print(f"[main] Channel has {len(channel.buffer)} leftover packet{'s' if len(channel.buffer) > 1 else ''} of data, clearing it") while await channel.pending(): - print(f"Cleared {await channel.read()!r}") + print(f"[main] Cleared {await channel.read()!r}") channel = giambio.MemoryChannel() -giambio.run(main, channel, debugger=()) \ No newline at end of file +giambio.run(main, channel, 6, debugger=()) \ No newline at end of file