orderedparallel

Documentation

Index

• func New(input chan interface{}, fn ProcessFn, parallelism int) chan interface{}
• type ProcessFn

Functions

func New

func New(input chan interface{}, fn ProcessFn, parallelism int) chan interface{}

Creates a pool of |parallelism| goroutines to process values off of |input| by calling |fn| and guarentees that results of each call will be sent on |out| in the order the corresponding input was received.

Types

type ProcessFn

type ProcessFn func(in interface{}) (out interface{})