worker

package

v0.7.0 Latest Latest Go to latest Published: Aug 17, 2025 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

View Source

var (
	// ErrReject makes Worker ignore the element.
	ErrReject = errors.New("Reject")
)

This section is empty.

type Chain[T any] struct {
	// contains filtered or unexported fields
}

func NewChain[T any](workers []*Worker[T, T], n int) *Chain[T]

func (j *Chain[T]) Start(ctx context.Context, inC <-chan T, outC chan<- T)

type Worker[In, Out any] struct {
	// contains filtered or unexported fields
}

func New[In, Out any](
	name string,
	n int,
	f func(context.Context, In) (Out, error),
) *Worker[In, Out]

func (w *Worker[In, Out]) Start(
	ctx context.Context,
	inC <-chan In,
	outC chan<- Out,
)