func (r *reqResReader) failed(err error) error {
	r.log.Debugf("reader failed: %v existing err: %v", err, r.err)
	if r.err != nil {
		return r.err
	}

	r.mex.shutdown()
	r.err = err
	return r.err
}
func (r *reqResReader) failed(err error) error {
	r.log.Debugf("reader failed: %v existing err: %v", err, r.err)
	if r.err != nil {
		return r.err
	}

	r.mex.shutdown()
	r.err = err
	return r.err
}
func ( r * reqResReader ) failed ( err error ) error { r . log . Debugf ( " " , err , r . err ) if r . err != nil { return r . err } r . mex . shutdown ( ) r . err = err return r . err }
// failed indicates the reader failed
failed indicates the reader failed