Method getOrCreateExchange

go/copilot_request_handler.go:570–580

getOrCreateExchange returns the exchange for requestID, allocating one if it does not yet exist. The runtime dispatches httpRequestStart and httpRequestChunk frames on separate goroutines (see jsonrpc2.handleRequest), so a body chunk — including the terminal end frame — can arrive before its start f

(requestID string)

// first touch means those chunks are buffered rather than dropped, instead of
// hanging the body drain forever.
func (a *copilotRequestAdapter) getOrCreateExchange(requestID string) *pendingExchange {
	a.mu.Lock()
	defer a.mu.Unlock()
	if exchange, ok := a.pending[requestID]; ok {
		return exchange
	}
	ctx, cancel := context.WithCancel(context.Background())
	exchange := &pendingExchange{queue: newFrameQueue(), ctx: ctx, cancel: cancel}
	a.pending[requestID] = exchange
	return exchange
}

func (a *copilotRequestAdapter) HttpRequestStart(params *rpc.LlmInferenceHTTPRequestStartRequest) (*rpc.LlmInferenceHTTPRequestStartResult, error) {
	// Adopt any exchange a racing chunk already created — with its buffered