Iterator-fed worker pool

cciterator.go

func ProcessConcurrently[T any](
    input iter.Seq[T],
    workerCount int,
    processor func(T) error,
) error {
    jobs := make(chan T, workerCount)
    errors := make(chan error, workerCount)
    
    // Start worker goroutines
    var wg sync.WaitGroup
    for i := 0; i < workerCount; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            for job := range jobs {
                if err := processor(job); err != nil {
                    errors <- err
                    return
                }
            }
        }()
    }
    
    // Feed iterator to jobs channel
    go func() {
        defer close(jobs)
        for item := range input {
            jobs <- item
        }
    }()
    
    wg.Wait()
    return checkErrors(errors)
}