Function drive

tests/shared/test_jsonrpc_dispatcher.py:293–295

()

    run_returned = anyio.Event()

    async def drive() -> None:
        await server.run(park, on_notify)
        run_returned.set()

    async with anyio.create_task_group() as tg:
        tg.start_soon(drive)