Function Map

transform.go:14–27

Map takes a stream of items of type A and transforms them into items of type B using a function f. Returns a new stream of transformed items. This is a non-blocking unordered function that processes items concurrently using n goroutines. An ordered version of this function, [OrderedMap], is also av

(in <-chan Try[A], n int, f func(A) (B, error))

//
// See the package documentation for more information on non-blocking unordered functions and error handling.
func Map[A, B any](in <-chan Try[A], n int, f func(A) (B, error)) <-chan Try[B] {
	return core.FilterMap(in, n, func(a Try[A]) (Try[B], bool) {
		if a.Error != nil {
			return Try[B]{Error: a.Error}, true
		}

		b, err := f(a.Value)
		if err != nil {
			return Try[B]{Error: err}, true
		}

		return Try[B]{Value: b}, true
	})
}

// OrderedMap is the ordered version of [Map].
func OrderedMap[A, B any](in <-chan Try[A], n int, f func(A) (B, error)) <-chan Try[B] {