(params *rpc.LlmInferenceHTTPRequestChunkRequest)
| 630 | } |
| 631 | |
| 632 | func (a *copilotRequestAdapter) HttpRequestChunk(params *rpc.LlmInferenceHTTPRequestChunkRequest) (*rpc.LlmInferenceHTTPRequestChunkResult, error) { |
| 633 | // May arrive before the matching start frame (frames are dispatched on |
| 634 | // separate goroutines); get-or-create so the body is buffered, never lost. |
| 635 | exchange := a.getOrCreateExchange(params.RequestID) |
| 636 | a.routeChunk(exchange, params) |
| 637 | return &rpc.LlmInferenceHTTPRequestChunkResult{}, nil |
| 638 | } |
| 639 | |
| 640 | func (a *copilotRequestAdapter) routeChunk(exchange *pendingExchange, params *rpc.LlmInferenceHTTPRequestChunkRequest) { |
| 641 | if params.Cancel != nil && *params.Cancel { |
nothing calls this directly
no test coverage detected