async

Documentation

Index

• func Map[T any, N any](count, size int, mp func(T) N, in <-chan T) pipes.ChanPull[N]
• func MapWithError[T any, N any](count, size int, mp func(T) (N, error), in <-chan T) (pipes.ChanPull[N], pipes.ChanPull[error])
• func MapWithErrorSink[T any, N any](count, size int, mp func(T) (N, error), sink func(error), in <-chan T) pipes.ChanPull[N]

Functions

func Map

func Map[T any, N any](count, size int, mp func(T) N, in <-chan T) pipes.ChanPull[N]

really the big thing that isn't obvious here is you lose any ordering going through damn near everything in the package as planned lol.

func MapWithError

func MapWithError[T any, N any](count, size int, mp func(T) (N, error), in <-chan T) (pipes.ChanPull[N], pipes.ChanPull[error])

func MapWithErrorSink

func MapWithErrorSink[T any, N any](count, size int, mp func(T) (N, error), sink func(error), in <-chan T) pipes.ChanPull[N]