BreakWithError causes the next Read (waking up a current blocked Read if needed) to return the provided err immediately, without waiting for unread data.
(err error)
| 114 | // Read if needed) to return the provided err immediately, without |
| 115 | // waiting for unread data. |
| 116 | func (p *pipe) BreakWithError(err error) { p.closeWithError(&p.breakErr, err, nil) } |
| 117 | |
| 118 | // closeWithErrorAndCode is like CloseWithError but also sets some code to run |
| 119 | // in the caller's goroutine before returning the error. |