()
| 721 | } |
| 722 | |
| 723 | func (s *responseSink) rpcAPI() (*rpc.ServerLlmInferenceAPI, error) { |
| 724 | r := s.adapter.getRPC() |
| 725 | if r == nil { |
| 726 | return nil, fmt.Errorf("CopilotRequestHandler response sink used after RPC connection closed") |
| 727 | } |
| 728 | return r, nil |
| 729 | } |
| 730 | |
| 731 | func (s *responseSink) start(status int, statusTxt string, headers http.Header) error { |
| 732 | s.exchange.mu.Lock() |