Method run

tests/test_query_engine.py:59–61

()

        collected = []

        async def run():
            async for msg in engine.submit_message("Hello"):
                collected.append(msg)

        _run(run())