Function streamResponseToSink

go/copilot_request_handler.go:218–240

(resp *http.Response, sink *responseSink)

}

func streamResponseToSink(resp *http.Response, sink *responseSink) error {
	if err := sink.start(resp.StatusCode, statusText(resp), cloneHeader(resp.Header)); err != nil {
		return err
	}
	buf := make([]byte, 32*1024)
	for {
		n, readErr := resp.Body.Read(buf)
		if n > 0 {
			// writeText copies eagerly via string(...), so the reused read
			// buffer can be passed directly without an extra per-chunk alloc.
			if err := sink.writeText(buf[:n]); err != nil {
				return err
			}
		}
		if readErr == io.EOF {
			break
		}
		if readErr != nil {
			return sink.sinkError(readErr.Error(), "")
		}
	}
	return sink.end()
}

func statusText(resp *http.Response) string {
	return strings.TrimSpace(strings.TrimPrefix(resp.Status, strconv.Itoa(resp.StatusCode)))