(b []byte)
| 288 | } |
| 289 | |
| 290 | func (r *cancelingReader) Read(b []byte) (int, error) { |
| 291 | n, err := r.r.Read(b) |
| 292 | if err != nil && err != io.EOF { |
| 293 | r.str.CancelWrite(quic.StreamErrorCode(ErrCodeRequestCanceled)) |
| 294 | } |
| 295 | return n, err |
| 296 | } |
| 297 | |
| 298 | func (c *ClientConn) sendRequestBody(str *RequestStream, body io.ReadCloser, contentLength int64, dumps []*dump.Dumper) error { |
| 299 | defer body.Close() |
nothing calls this directly
no test coverage detected