Function Map

pkg/stream/stream.go:616–620

Map 对流中的每个值应用函数

(r *Reader[T], fn func(T) U)

// Map 对流中的每个值应用函数
func Map[T, U any](r *Reader[T], fn func(T) U) *Reader[U] {
	return TransformSimple(r, func(v T) (U, error) {
		return fn(v), nil
	})
}

// Take 返回只产出前 n 个值的读取器
func Take[T any](r *Reader[T], n int) *Reader[T] {