pipeline

type Result[I any] struct {
	Err  error
	Item *I
}

type WorkOptions[I any, O any] struct {
	Input          <-chan Result[I]
	Workers        int
	Process        func(I) (O, error)
	Name           string
	MetricsEnabled bool
}