Method drainer

Lib/test/test_asyncio/test_streams.py:873–876

(stream)

        drained = 0

        async def drainer(stream):
            nonlocal drained
            await stream._drain_helper()
            drained += 1

        async def main():
            loop = asyncio.get_running_loop()