Function NewReadAtSeeker

internal/stream/stream.go:405–430

(ss *SeekableStream, offset int64, forceRange ...bool)

}

func NewReadAtSeeker(ss *SeekableStream, offset int64, forceRange ...bool) (model.File, error) {
	if cache := ss.GetFile(); cache != nil {
		_, err := cache.Seek(offset, io.SeekStart)
		if err != nil {
			return nil, err
		}
		return cache, nil
	}
	r := &RangeReadReadAtSeeker{
		ss:        ss,
		masterOff: offset,
	}
	if offset != 0 || utils.IsBool(forceRange...) {
		if offset < 0 || offset > ss.GetSize() {
			return nil, errors.New("offset out of range")
		}
		reader, err := r.getReaderAtOffset(offset)
		if err != nil {
			return nil, err
		}
		r.readerMap.Store(int64(offset), reader)
	} else {
		r.readerMap.Store(int64(offset), ss)
	}
	return r, nil
}

func NewMultiReaderAt(ss []*SeekableStream) (readerutil.SizeReaderAt, error) {
	readers := make([]readerutil.SizeReaderAt, 0, len(ss))