Method Terminate

internal/uploadreader/upload_reader.go:56–61

Terminate waits for in-progress Read calls, if any, to finish, and ensures that after this function returns, any Read calls will fail with the provided error, and the underlying reader will never be used any more. It is safe to call this from a different goroutine than Read.

(err error)

//
// It is safe to call this from a different goroutine than Read.
func (ur *UploadReader) Terminate(err error) {
	ur.mutex.Lock() // May block for some time if ur.reader.Read() is in progress
	defer ur.mutex.Unlock()

	ur.terminationError = err
}