async def METHOD_NAME() -> None:
    async for _ in async_streaming_bulk(es2, async_gen()):
        pass
    async for _ in async_streaming_bulk(es2, async_gen().__aiter__()):
        pass
    async for _ in async_streaming_bulk(es2, [{"key": "value"}]):
        pass