concurrency

func Batch[T any](ch <-chan T, size int) <-chan []T

func FanIn[T any](streams ...<-chan T) <-chan T

func FanOut[T any](ch chan T, size int, ordered bool) []<-chan T

func Parallel[IN, OUT any](stream <-chan IN, fn func(IN) OUT, count int) <-chan OUT

func Pipeline[IN, OUT any](fn func(IN) OUT) func(<-chan IN) <-chan OUT