Function ReadArray

msgp/iter.go:18–40

ReadArray returns an iterator that can be used to iterate over the elements of an array in the MessagePack data while being read by the provided Reader. The type parameter V specifies the type of the elements in the array. The returned iterator implements the iter.Seq[V] interface, allowing for sequ

(m *Reader, readFn func() (T, error))

// allowing for sequential access to the array elements.
// The iterator will always stop after one error has been encountered.
func ReadArray[T any](m *Reader, readFn func() (T, error)) iter.Seq2[T, error] {
	return func(yield func(T, error) bool) {
		// Check if nil
		if m.IsNil() {
			m.ReadNil()
			return
		}
		// Regular array.
		var empty T
		length, err := m.ReadArrayHeader()
		if err != nil {
			yield(empty, fmt.Errorf("cannot read array header: %w", err))
			return
		}
		for range length {
			var v T
			v, err = readFn()
			if !yield(v, err) || err != nil {
				return
			}
		}
	}
}

// WriteArray writes an array to the provided Writer.
// The writeFn parameter specifies the function to use to write each element of the array.