Method start

go/copilot_request_handler.go:731–763

(status int, statusTxt string, headers http.Header)

}

func (s *responseSink) start(status int, statusTxt string, headers http.Header) error {
	s.exchange.mu.Lock()
	if s.exchange.started {
		s.exchange.mu.Unlock()
		return fmt.Errorf("CopilotRequestHandler response sink Start() called twice")
	}
	if s.exchange.finished {
		s.exchange.mu.Unlock()
		return fmt.Errorf("CopilotRequestHandler response sink already finished")
	}
	s.exchange.started = true
	s.exchange.mu.Unlock()

	api, err := s.rpcAPI()
	if err != nil {
		return err
	}
	var st *string
	if statusTxt != "" {
		st = &statusTxt
	}
	h := map[string][]string(headers)
	if h == nil {
		h = map[string][]string{}
	}
	_, err = api.HttpResponseStart(context.Background(), &rpc.LlmInferenceHTTPResponseStartRequest{
		RequestID:  s.requestID,
		Status:     int64(status),
		StatusText: st,
		Headers:    h,
	})
	return err
}

func (s *responseSink) writeText(data []byte) error {
	return s.writeRaw(string(data), false)