async function method<R>(
fn: (() => Promise<R>)[],
concurrency: number,
) {
const tasks = fn.map(c =>
Effect.promise(c)
)
let effect = Effect.all(tasks, {
concurrency: concurrency,
})
const results = await Effect.runPromise(effect)
return results
}
async function method<R>(
fn: (() => Promise<R>)[],
concurrency: number,
) {
const tasks = fn.map(c =>
Effect.promise(c)
)
let effect = Effect.all(tasks, {
concurrency: concurrency,
})
const results = await Effect.runPromise(effect)
return results
}