Versions in this module Expand all Collapse all v0 v0.0.2 Nov 1, 2022 v0.0.1 Aug 7, 2022 Changes in this version + func Execute(ctx context.Context, pipeline Pipeline[T], in T) (out T, err error) + func Parallel(ctx context.Context, pipeline Pipeline[[]T], in []T, jobs int) (out []T, err error) + type HandlerFunc func(ctx context.Context, in T) (out T, err error) + func ForEach(handle HandlerFunc[T]) HandlerFunc[[]T] + type Pipeline []HandlerFunc[T]
Go to main page