(handler *CopilotRequestHandler, getRPC func() *rpc.ServerLlmInferenceAPI)
| 553 | } |
| 554 | |
| 555 | func newCopilotRequestAdapter(handler *CopilotRequestHandler, getRPC func() *rpc.ServerLlmInferenceAPI) rpc.LlmInferenceHandler { |
| 556 | return &copilotRequestAdapter{ |
| 557 | handler: handler, |
| 558 | getRPC: getRPC, |
| 559 | pending: make(map[string]*pendingExchange), |
| 560 | } |
| 561 | } |
| 562 | |
| 563 | // getOrCreateExchange returns the exchange for requestID, allocating one if it |
| 564 | // does not yet exist. The runtime dispatches httpRequestStart and |
no outgoing calls
no test coverage detected
searching dependent graphs…