(ss []*SeekableStream)
| 430 | } |
| 431 | |
| 432 | func NewMultiReaderAt(ss []*SeekableStream) (readerutil.SizeReaderAt, error) { |
| 433 | readers := make([]readerutil.SizeReaderAt, 0, len(ss)) |
| 434 | for _, s := range ss { |
| 435 | ra, err := NewReadAtSeeker(s, 0) |
| 436 | if err != nil { |
| 437 | return nil, err |
| 438 | } |
| 439 | readers = append(readers, io.NewSectionReader(ra, 0, s.GetSize())) |
| 440 | } |
| 441 | return readerutil.NewMultiReaderAt(readers...), nil |
| 442 | } |
| 443 | |
| 444 | func (r *RangeReadReadAtSeeker) getReaderAtOffset(off int64) (io.Reader, error) { |
| 445 | for { |
no test coverage detected