async def merge_async_generator(gen):
    """
    Takes in an async generator that should yield dictionaries
    and iterates through it merging them all together.
    """
    combined = {}
    async for val in gen:
        combined.update(val)
    return combined