Function ForEach

pkg/stream/stream.go:649–663

ForEach 消费读取器中的所有值，对每个值调用 fn

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

// ForEach 消费读取器中的所有值，对每个值调用 fn
func ForEach[T any](r *Reader[T], fn func(T) error) error {
	defer r.Close()
	for {
		v, err := r.Recv()
		if errors.Is(err, io.EOF) {
			return nil
		}
		if err != nil {
			return err
		}
		if err := fn(v); err != nil {
			return err
		}
	}
}