[issue46568] non awaited coroutines on a IsolatedAsyncioTestCase results on a RuntimeWarning

Andrew Svetlov added the comment: You are welcome! -- ___ Python tracker ___ ___ Python-bugs-list mailing list Unsubscribe:

[issue46568] non awaited coroutines on a IsolatedAsyncioTestCase results on a RuntimeWarning

Change by Andrew Svetlov : -- resolution: -> not a bug stage: -> resolved status: open -> closed ___ Python tracker ___ ___

[issue46568] non awaited coroutines on a IsolatedAsyncioTestCase results on a RuntimeWarning

bluecarrot added the comment: You are absolutely correct. Thank you very much! -- ___ Python tracker ___ ___ Python-bugs-list

[issue46568] non awaited coroutines on a IsolatedAsyncioTestCase results on a RuntimeWarning

Andrew Svetlov added the comment: Your version works but can be simplified. Just use await writer.drain() writer.write(data) without grabbing the drainer early. The purpose of the .drain() method is to write pausing if the write buffer side is greater than the high watermark.

[issue46568] non awaited coroutines on a IsolatedAsyncioTestCase results on a RuntimeWarning

bluecarrot added the comment: Hi Andrew, thank you for your answer. I am experimenting with coroutines, as I am pretty new to them. My idea was to let the writer drain while other packets where read, and thus I am waiting for the writer_drain right before starting writer.write again. Isn't

[issue46568] non awaited coroutines on a IsolatedAsyncioTestCase results on a RuntimeWarning

Andrew Svetlov added the comment: Your code has at least one concurrency problem. Let's look back at forward_stream() function: async def forward_stream(reader: StreamReader, writer: StreamWriter, event: asyncio.Event, source: str): writer_drain = writer.drain() # <--- awaitable is

[issue46568] non awaited coroutines on a IsolatedAsyncioTestCase results on a RuntimeWarning

bluecarrot added the comment: Seems that, should I add an "await asyncio.sleep(1)" in asyncTearDown, so getting class TestConnections(IsolatedAsyncioTestCase): async def asyncSetUp(self) -> None: self.proxy = asyncio.create_task(EnergyAgentProxy(self.proxy_port,

[issue46568] non awaited coroutines on a IsolatedAsyncioTestCase results on a RuntimeWarning

New submission from bluecarrot : I am unittesting a tcp proxy module using coroutines. This is the coroutine I am using to do the forwarding, allowing the writer stream to drain while the rest of the coroutines are proceeding: async def forward_stream(reader: StreamReader, writer: