test cleanup

Author: jell-o-fishi

rsocket/async_helpers.py

@@ -4,4 +4,4 @@
 async def async_range(count: int):
     for i in range(count):
         yield i
-        await asyncio.sleep(0.0)
+        await asyncio.sleep(0)

tests/rsocket/test_concurrency.py

@@ -40,7 +40,7 @@ async def generator():
 
     results = (await request_1, await request_2)
 
-    print(results)
+    print(results[0].delta, results[1].delta)
     delta = abs(results[0].delta - results[1].delta)
 
     assert len(results[0].result) == 2000
@@ -70,5 +70,3 @@ async def request_response(self, request: Payload):
         assert len(results[0].result.data) == 10000 * 100
         assert len(results[1].result.data) == 10 * 100
         assert delta > 0.2
-
-        await asyncio.sleep(2)

tests/tools/fixtures_quart.py

@@ -30,7 +30,7 @@ async def ws():
     client_arguments = client_arguments or {}
     # client_arguments.update(test_overrides)
     server_task = asyncio.create_task(app.run_task(port=unused_tcp_port))
-    await asyncio.sleep(0.1)
+    await asyncio.sleep(0)
 
     async with websocket_client('http://localhost:{}'.format(unused_tcp_port),
                                 **client_arguments) as client: