func()

in tools/mc2bq/pkg/export/export.go [228:253]


func (r *objectReader[T]) Read(buf []byte) (int, error) {
	if len(buf) == 0 {
		return 0, nil
	}

	if len(r.buf) == 0 {
		asset, err := r.it.Next()
		if errors.Is(err, iterator.Done) {
			return 0, io.EOF
		}
		if err != nil {
			return 0, err
		}
		r.buf, err = r.serializer(asset)
		if err != nil {
			return 0, err
		}
		r.objectsRead++
	}

	n := copy(buf, r.buf)
	r.bytesRead += uint64(n)
	r.buf = r.buf[n:]

	return n, nil
}