Method Read

cf/net/progress_reader.go:32–58

(p []byte)

}

func (progressReader *ProgressReader) Read(p []byte) (int, error) {
	if progressReader.ioReadSeeker == nil {
		return 0, os.ErrInvalid
	}

	n, err := progressReader.ioReadSeeker.Read(p)

	if progressReader.total > int64(0) {
		if n > 0 {
			if progressReader.quit == nil {
				progressReader.quit = make(chan bool)
				go progressReader.printProgress(progressReader.quit)
			}

			progressReader.mutex.Lock()
			progressReader.bytesRead += int64(n)
			progressReader.mutex.Unlock()

			if progressReader.total == progressReader.bytesRead {
				progressReader.quit <- true
				return n, err
			}
		}
	}

	return n, err
}

func (progressReader *ProgressReader) Seek(offset int64, whence int) (int64, error) {
	return progressReader.ioReadSeeker.Seek(offset, whence)