Method run

tests/test_query_loop.py:327–329

()

        collected = []

        async def run():
            async for msg in query(params):
                collected.append(msg)

        _run(run())