Merge pull request #2644 from pikasTech/fix/l1-kafka-sse-cli-cancel

忽略 SSE 主动清理的连接重置
2026-07-18 12:11:47 +08:00
parent 193fd57be6 93de94e033
commit 527a177923
1 changed files with 1 additions and 1 deletions
@@ -71,7 +71,7 @@ async function inspectEvents(parsed: Parsed, env: Record<string, string | undefi
        const frame = parseSseBlock(block);
        if (frame) frames.push(frame);
        if (frames.filter((entry) => entry.name === "hwlab.event.v1").length >= minEvents) {
-          await reader.cancel();
+          await reader.cancel().catch(() => undefined);
          break readStream;
        }
        boundary = buffer.indexOf("\n\n");