Promise all with limited concurrency promise running

limistedPromiseAll.ts

async function limitedPromiseAll<T>(promises: (() => Promise<T>)[], limit: number) {
    const promisesCopy = promises.slice()
    const factory = function () {
        return promisesCopy.shift()
    }

    const results: T[] = []
    const pipelines: (() => Promise<T>)[] = []
    while (pipelines.length < limit) {
        const pipline = async () => {
            let promise = factory()
            while (promise) {
                const result = await promise()
                results.push(result)
                promise = factory()
            }
        }
        pipelines.push(pipline)
    }
    await Promise.all(pipelines.map(pipeline => pipeline()))
    return results
}

Note: This gist needs async await grammar support.