@@ -0,0 +1,557 @@
+import weakref%0A%0Afrom tests import BaseTestCase%0A%0A%0Aclass TestCase(BaseTestCase):%0A%0A    async def test_on_successful_cleanup_message(self):%0A        rabbitmq_connection = await self.create_connection()%0A%0A        weakset = weakref.WeakSet()%0A%0A        async def f(rabbitmq_connection, weakset):%0A            async with rabbitmq_connection.channel() as channel:%0A                weakset.add(channel)%0A%0A        async with rabbitmq_connection:%0A            for i in range(5):%0A                await f(rabbitmq_connection, weakset)%0A%0A        self.assertEqual(len(weakset), 0)%0A

Add test on memory leak