pipeline

Documentation

Index

• func Consumer[T any](ctx context.Context, cancelFunc context.CancelFunc, values <-chan T, ...) error
• func Producer[T any](ctx context.Context, input []T) <-chan T
• func Step[In any, Out any](ctx context.Context, inChan <-chan In, outChan chan<- Out, ...)

Functions

func Consumer

func Consumer[T any](ctx context.Context, cancelFunc context.CancelFunc, values <-chan T, operation func(T) error, errors <-chan error) error

func Producer

func Producer[T any](ctx context.Context, input []T) <-chan T

func Step

func Step[In any, Out any](ctx context.Context,
	inChan <-chan In,
	outChan chan<- Out,
	errChan chan<- error,
	transform func(In) (Out, error),
)