revert name change

pool/result_context_pool.go

@@ -14,7 +14,7 @@ import (
 type ResultContextPool[T any] struct {
 	contextPool    ContextPool
 	agg            resultAggregator[T]
-	includeErrored bool
+	collectErrored bool
 }
 
 // Go submits a task to the pool. If all goroutines in the pool
@@ -32,15 +32,15 @@ func (p *ResultContextPool[T]) Go(f func(context.Context) (T, error)) {
 // returns an error if any of the tasks errored.
 func (p *ResultContextPool[T]) Wait() ([]T, error) {
 	err := p.contextPool.Wait()
-	return p.agg.collect(p.includeErrored), err
+	return p.agg.collect(p.collectErrored), err
 }
 
 // WithCollectErrored configures the pool to still collect the result of a task
 // even if the task returned an error. By default, the result of tasks that errored
 // are ignored and only the error is collected.
 func (p *ResultContextPool[T]) WithCollectErrored() *ResultContextPool[T] {
 	p.panicIfInitialized()
-	p.includeErrored = true
+	p.collectErrored = true
 	return p
 }
 

pool/result_error_pool.go

@@ -16,7 +16,7 @@ import (
 type ResultErrorPool[T any] struct {
 	errorPool      ErrorPool
 	agg            resultAggregator[T]
-	includeErrored bool
+	collectErrored bool
 }
 
 // Go submits a task to the pool. If all goroutines in the pool
@@ -34,15 +34,15 @@ func (p *ResultErrorPool[T]) Go(f func() (T, error)) {
 // returning the results and any errors from tasks.
 func (p *ResultErrorPool[T]) Wait() ([]T, error) {
 	err := p.errorPool.Wait()
-	return p.agg.collect(p.includeErrored), err
+	return p.agg.collect(p.collectErrored), err
 }
 
 // WithCollectErrored configures the pool to still collect the result of a task
 // even if the task returned an error. By default, the result of tasks that errored
 // are ignored and only the error is collected.
 func (p *ResultErrorPool[T]) WithCollectErrored() *ResultErrorPool[T] {
 	p.panicIfInitialized()
-	p.includeErrored = true
+	p.collectErrored = true
 	return p
 }
 

pool/result_pool.go

@@ -118,12 +118,12 @@ func (r *resultAggregator[T]) save(i int, res T, errored bool) {
 }
 
 // collect returns the set of aggregated results.
-func (r *resultAggregator[T]) collect(includeErrored bool) []T {
+func (r *resultAggregator[T]) collect(collectErrored bool) []T {
 	if !r.mu.TryLock() {
 		panic("collect should not be called until all goroutines have exited")
 	}
 
-	if includeErrored || len(r.errored) == 0 {
+	if collectErrored || len(r.errored) == 0 {
 		return r.results
 	}