Method foreachChunk

pkg/schema/filereader.go:222–248

(ctx context.Context, fn func([]blob.Ref, BytesPart) error, path []blob.Ref)

}

func (fr *FileReader) foreachChunk(ctx context.Context, fn func([]blob.Ref, BytesPart) error, path []blob.Ref) error {
	path = append(path, fr.ss.BlobRef)
	for _, bp := range fr.ss.Parts {
		if bp.BytesRef.Valid() && bp.BlobRef.Valid() {
			return fmt.Errorf("part in %v illegally contained both a blobRef and bytesRef", fr.ss.BlobRef)
		}
		if bp.BytesRef.Valid() {
			ss, err := fr.getSuperset(ctx, bp.BytesRef)
			if err != nil {
				return err
			}
			subfr, err := ss.NewFileReader(fr.fetcher)
			if err != nil {
				return err
			}
			subfr.parent = fr
			if err := subfr.foreachChunk(ctx, fn, path); err != nil {
				return err
			}
		} else {
			if err := fn(path, *bp); err != nil {
				return err
			}
		}
	}
	return nil
}

func (fr *FileReader) rootReader() *FileReader {
	if fr.parent != nil {