diff --git a/tests/rpc_pipeline_test.py b/tests/rpc_pipeline_test.py index 82b0b4e..20627f0 100644 --- a/tests/rpc_pipeline_test.py +++ b/tests/rpc_pipeline_test.py @@ -212,7 +212,7 @@ def communicate(): self.assertIsInstance(task, asyncio.Task) server.close() yield from server.wait_closed() - yield from asyncio.sleep(0, loop=self.loop) + yield from asyncio.sleep(.1, loop=self.loop) self.assertEqual(0, len(server._proto.pending_waiters)) fut.cancel() diff --git a/tests/rpc_pubsub_test.py b/tests/rpc_pubsub_test.py index 032f622..8951942 100644 --- a/tests/rpc_pubsub_test.py +++ b/tests/rpc_pubsub_test.py @@ -349,7 +349,7 @@ def communicate(): self.assertIsInstance(task, asyncio.Task) server.close() yield from server.wait_closed() - yield from asyncio.sleep(0, loop=self.loop) + yield from asyncio.sleep(.1, loop=self.loop) self.assertEqual(0, len(server._proto.pending_waiters)) fut.cancel()