Function wait

python/e2e/test_multi_client_e2e.py:200–204

()

    unsubscribe = session.on(on_event)

    async def wait():
        try:
            return await asyncio.wait_for(future, timeout=timeout)
        finally:
            unsubscribe()

    return loop.create_task(wait())