Method run

tests/test_ws5_integration.py:434–436

()

        collected = []

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

        _run(run())