Fix a test that was leaving unprocessed tasks after the test

The request was cancelled fast enough, and the response writer was closed. But the response handler continued to try writing to that closed transport if not cancelled fast enough. Now, it will ignore such writing errors too.

Signed-off-by: Sergey Vasilyev <[email protected]>

tests/apis/test_api_requests.py

@@ -236,15 +236,19 @@ async def serve_slowly():
 async def test_stopper_in_streams(
         resp_mocker, aresponses, hostname, method, delay, expected, settings, logger):
 
-    async def stream_slowly(request: aiohttp.ClientRequest):
+    async def stream_slowly(request: aiohttp.web.Request) -> aiohttp.web.StreamResponse:
         response = aiohttp.web.StreamResponse()
         await response.prepare(request)
-        await asyncio.sleep(0.05)
-        await response.write(b'{"fake": "result1"}\n')
-        await asyncio.sleep(0.15)
-        await response.write(b'{"fake": "result2"}\n')
-        await response.write_eof()
-        return response
+        try:
+            await asyncio.sleep(0.05)
+            await response.write(b'{"fake": "result1"}\n')
+            await asyncio.sleep(0.15)
+            await response.write(b'{"fake": "result2"}\n')
+            await response.write_eof()
+        except ConnectionError:
+            pass  # usually when the client cancelled the request and closed the connection
+        finally:
+            return response
 
     aresponses.add(hostname, '/url', method, stream_slowly)