( payload: CursorRequestPayload, accessToken: string, modelId: string, bridgeKey: string, convKey: string, )
| 1336 | } |
| 1337 | |
| 1338 | function handleStreamingResponse( |
| 1339 | payload: CursorRequestPayload, |
| 1340 | accessToken: string, |
| 1341 | modelId: string, |
| 1342 | bridgeKey: string, |
| 1343 | convKey: string, |
| 1344 | ): Response { |
| 1345 | const { bridge, heartbeatTimer } = startBridge(accessToken, payload.requestBytes); |
| 1346 | return createBridgeStreamResponse( |
| 1347 | bridge, heartbeatTimer, |
| 1348 | payload.blobStore, payload.mcpTools, |
| 1349 | modelId, bridgeKey, convKey, |
| 1350 | ); |
| 1351 | } |
| 1352 | |
| 1353 | /** Resume a paused bridge by sending MCP results and continuing to stream. */ |
| 1354 | function handleToolResultResume( |
no test coverage detected