Searched refs:bufPipe (Results 1 – 1 of 1) sorted by relevance
196 bufPipe pipe // buffered pipe with the flow-controlled response payload member247 cs.bufPipe.CloseWithError(err)1466 cs.bufPipe.CloseWithError(err) // no-op if already closed1689 cs.bufPipe = pipe{b: &dataBuffer{expected: res.ContentLength}}1746 n, err = b.cs.bufPipe.Read(p)1782 v := int(cs.inflow.available()) + cs.bufPipe.Len()1808 serverSentStreamEnd := cs.bufPipe.Err() == io.EOF1809 unread := cs.bufPipe.Len()1828 cs.bufPipe.BreakWithError(errClosedResponseBody)1915 if _, err := cs.bufPipe.Write(data); err != nil {[all …]