worker

Documentation

Index

• func ProcessArray(ctx context.Context, data []interface{}, ...) ([]interface{}, error)

Functions

func ProcessArray

func ProcessArray(ctx context.Context, data []interface{},
	fn func(context.Context, interface{}) (interface{}, error)) ([]interface{}, error)

ProcessArray asynchronously processes an array, spinning up n (n being number of CPUs) goroutine worker instances. ProcessArray blocks until the workers have all finished