import { Console, Effect } from "effect"

const task = (id: number) =>
  Effect.gen(function*() {
    yield* Console.log(`Task ${id} starting`)
    yield* Effect.sleep("100 millis")
    yield* Console.log(`Task ${id} completed`)
    return id
  })

// Run tasks with limited concurrency (max 2 at a time)
const program = Effect.gen(function*() {
  const tasks = [1, 2, 3, 4, 5].map(task)
  return yield* Effect.all(tasks, { concurrency: 2 })
}).pipe(
  Effect.withConcurrency(2)
)

Effect.runPromise(program).then(console.log)
// Tasks will run with max 2 concurrent operations
// [1, 2, 3, 4, 5]