Method sinkError

go/copilot_request_handler.go:824–850

(message string, code string)

}

func (s *responseSink) sinkError(message string, code string) error {
	s.exchange.mu.Lock()
	if s.exchange.finished {
		s.exchange.mu.Unlock()
		return nil
	}
	s.exchange.finished = true
	s.exchange.mu.Unlock()
	s.adapter.removePending(s.requestID)
	api, err := s.rpcAPI()
	if err != nil {
		return err
	}
	end := true
	chunkErr := &rpc.LlmInferenceHTTPResponseChunkError{Message: message}
	if code != "" {
		c := code
		chunkErr.Code = &c
	}
	_, err = api.HttpResponseChunk(context.Background(), &rpc.LlmInferenceHTTPResponseChunkRequest{
		RequestID: s.requestID,
		Data:      "",
		End:       &end,
		Error:     chunkErr,
	})
	return err
}