{"record":{"id":"a81dc6ec3804a164","repo":"diegosouzapw/OmniRoute","slug":"kimi-connect-endstream-error-endstreamerror","errorCode":null,"errorMessage":"Kimi Connect EndStream error: ${endStreamError}","messagePattern":"Kimi Connect EndStream error: (.+?)","errorType":"exception","errorClass":"Error","httpStatus":null,"severity":"error","filePath":"open-sse/executors/kimi-web.ts","lineNumber":491,"sourceCode":"              if (value) {\n                const merged = new Uint8Array(buffer.length + value.length);\n                merged.set(buffer, 0);\n                merged.set(value, buffer.length);\n                buffer = merged;\n\n                let offset = 0;\n                while (offset < buffer.length) {\n                  const { consumed, frame } = decodeConnectFrame(buffer, offset);\n                  if (consumed === -1) {\n                    throw new Error(\"Kimi Connect frame exceeded MAX_FRAME_LEN\");\n                  }\n                  if (consumed === 0) break; // need more bytes\n                  offset += consumed;\n                  if (!frame) continue;\n                  if ((frame.flags & 0x02) !== 0) {\n                    const endStreamError = getConnectEndStreamError(frame);\n                    if (endStreamError) {\n                      throw new Error(`Kimi Connect EndStream error: ${endStreamError}`);\n                    }\n                    if (!emittedRole) {\n                      emitChunk(controller, { role: \"assistant\", content: \"\" });\n                    }\n                    emitChunk(controller, {}, \"stop\");\n                    controller.enqueue(encoder.encode(\"data: [DONE]\\n\\n\"));\n                    controller.close();\n                    return;\n                  }\n                  if (!frame.message) continue;\n\n                  const delta = extractDelta(frame.message);\n                  if (delta) {\n                    if (!emittedRole) {\n                      emittedRole = true;\n                      emitChunk(controller, { role: \"assistant\", content: \"\" });\n                    }\n                    if (delta.kind === \"think\") {","sourceCodeStart":473,"sourceCodeEnd":509,"githubUrl":"https://github.com/diegosouzapw/OmniRoute/blob/a179ffed5bb2e0b883b9ae7214ce8717b2a94c4d/open-sse/executors/kimi-web.ts#L473-L509","documentation":"Error \"Kimi Connect EndStream error: ${endStreamError}\" thrown in diegosouzapw/OmniRoute.","triggerScenarios":"Thrown at open-sse/executors/kimi-web.ts:491 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":[],"exampleFix":null,"handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"a179ffed5bb2e0b883b9ae7214ce8717b2a94c4d","analyzedAt":"2026-08-25T18:35:09.898Z","schemaVersion":2},"datasetVersion":"2026-08-25T21:54:21.419Z"}