Go iter.Seq2 如何遍历带错误结果的键值对

如果一组输入需要“逐条处理，同时把行号和错误带出来”，可以把迭代器的两个值设计成 int 和 error。Go 的 iter.Seq2[K, V] 正好表示这种成对结果：它不会替你解释第二个值是不是错误，也不会因为错误非空就自动停止；消费方必须明确选择记录、跳过还是中断。

先看清 iter.Seq2 的两个值分别负责什么

iter.Seq2[K, V] 的定义是 func(yield func(K, V) bool)。这里的 K、V 只是一次迭代送出的两个值，最常见的是键和值，也可以是行号和错误。下面的例子把第二个值明确设为 error：

type RowErrors iter.Seq2[int, error]

// RowErrors 让调用方同时拿到输入行号和该行的校验错误。
var _ iter.Seq2[int, error] = RowErrors(nil)

这段类型声明本身不产生结果，只是帮助阅读者看到契约。真正有意义的动作发生在迭代器调用 yield(lineNo, err) 时。Go 1.23 开始，符合这种签名的函数可以直接放在 range 右侧；模块的语言版本也要至少写成 1.23。

让生产者为每条记录返回行号和 error

下面定义一个只负责校验的 ValidateRows。输入为空或去掉空白后没有内容时返回错误，其他行视为通过。注意：错误被作为第二个值送出后，迭代器仍可以继续下一行。

package main

import (
    "errors"
    "fmt"
    "iter"
    "strings"
)

// validateRow 只做当前行的规则判断，不决定整个序列是否停止。
func validateRow(raw string) error {
    if strings.TrimSpace(raw) == "" {
        return errors.New("内容为空")
    }
    return nil
}

// ValidateRows 把行号作为 K，把校验结果作为 V 送给调用方。
func ValidateRows(rows []string) iter.Seq2[int, error] {
    return func(yield func(int, error) bool) {
        for lineNo, raw := range rows {
            err := validateRow(raw)
            // yield 返回 false 表示调用方不再需要后续行，及时退出。
            if !yield(lineNo, err) {
                return
            }
        }
    }
}

func main() {
    rows := []string{"alice", "  ", "bob"}
    for lineNo, err := range ValidateRows(rows) {
        if err != nil {
            fmt.Printf("第%d行失败：%v\n", lineNo+1, err)
            continue
        }
        fmt.Printf("第%d行通过\n", lineNo+1)
    }
}

这个示例的输出应表达三次消费结果：

第1行通过
第2行失败：内容为空
第3行通过

这里的“失败”只是数据结果，不是迭代控制信号。生产者在第二行调用 yield 后收到了 true，所以继续产生第三行。

在 range 中决定继续、跳过还是停止

消费方通常把错误写入日志或错误集合，再用 continue 跳过当前业务动作。如果错误达到不可接受的条件，则使用 break。range 结束时会让当前的 yield 返回 false，生产者看到这个值后返回，从而完成清理。

// consumeRows 展示错误记录、继续处理和主动停止的区别。
func consumeRows(rows []string, stopAfter int) []error {
    var failures []error
    for lineNo, err := range ValidateRows(rows) {
        if err != nil {
            failures = append(failures, fmt.Errorf("第%d行：%w", lineNo+1, err))
            // continue 只跳过当前项，下一次 yield 仍会到来。
            if len(failures) >= stopAfter {
                break
            }
            continue
        }
        // 成功行在这里执行后续保存或转换逻辑。
    }
    return failures
}

如果 stopAfter 为 1，第二行产生错误后执行 break，第三行就不会再被消费。若想收集所有错误，应去掉这个 break，但仍要保留 continue，否则错误行会落入成功处理分支。

最容易混淆的三个边界

另外，不要把 iter.Seq2[int, error] 误认为专门的错误流类型。若每次还要传出业务对象，可以把 V 改成包含数据和错误的结构体，例如 iter.Seq2[int, RowResult]，或者定义三个字段的结果对象；关键是让成功、失败和停止策略在接口文档里写清楚。

常见问题

iter.Seq2 返回非 nil error 后会自动停止吗？

不会。error 只是第二个迭代值，是否继续由消费方的 continue、break 或正常走完循环决定。

为什么 yield 必须检查 bool？

因为调用方可能提前 break。不检查就可能继续读取输入、持有资源或发送无用结果，破坏迭代器的提前停止约定。

项目编译时报 range over function 错误怎么办？

检查 Go 工具链和 go.mod 的语言版本是否至少为 1.23；旧语言版本不会启用这种函数形式的 range 语法。

小结

用 iter.Seq2[int, error] 遍历带错误的键值对时，可以把行号放在 K，把错误放在 V。生产者只负责逐条调用 yield 并尊重其返回值，消费方再决定记录后继续还是立即停止。把这两个职责分开，代码既保留了惰性迭代的优势，也不会把错误结果和迭代控制混为一谈。