(
params: LlmInferenceHttpRequestStartRequest
)
| 378 | |
| 379 | return { |
| 380 | async httpRequestStart( |
| 381 | params: LlmInferenceHttpRequestStartRequest |
| 382 | ): Promise<LlmInferenceHttpRequestStartResult> { |
| 383 | // Adopt any exchange a racing chunk already created — with its |
| 384 | // buffered body — rather than dropping those frames. |
| 385 | const exchange = getOrCreate(params.requestId); |
| 386 | exchange.setContext(params); |
| 387 | void run(exchange); |
| 388 | return {}; |
| 389 | }, |
| 390 | async httpRequestChunk( |
| 391 | params: LlmInferenceHttpRequestChunkRequest |
| 392 | ): Promise<LlmInferenceHttpRequestChunkResult> { |
nothing calls this directly
no test coverage detected
searching dependent graphs…