Filter 创建只包含匹配谓词的值的新读取器
(r *Reader[T], predicate func(T) bool)
| 604 | |
| 605 | // Filter 创建只包含匹配谓词的值的新读取器 |
| 606 | func Filter[T any](r *Reader[T], predicate func(T) bool) *Reader[T] { |
| 607 | return TransformSimple(r, func(v T) (T, error) { |
| 608 | if predicate(v) { |
| 609 | return v, nil |
| 610 | } |
| 611 | return v, ErrSkip |
| 612 | }) |
| 613 | } |
| 614 | |
| 615 | // Map 对流中的每个值应用函数 |
| 616 | func Map[T, U any](r *Reader[T], fn func(T) U) *Reader[U] { |