func New()

in internal/preprocess/preprocessing.go [43:60]

• 15 lines of code
• 3 McCabe index (conditional complexity)

func New(ctx context.Context, in, out chan data.Entry, procs []Processor, options ...Option) (*Runner, error) {
	r := &Runner{
		in:    in,
		out:   out,
		procs: procs,
		log:   slog.Default(),
	}

	for _, o := range options {
		if err := o(r); err != nil {
			return nil, err
		}
	}

	go r.run(ctx)

	return r, nil
}