fix: SSE destroy not triggering error event and causing process exit, close #120 (#122)

pengzhanbo · web-flow · commit 753ada8f3db4 · 2025-08-14T01:27:55.000+08:00
diff --git a/plugin/src/core/sse.ts b/plugin/src/core/sse.ts
@@ -72,6 +72,14 @@ class SSEStream extends Transform {
   write(message: SSEMessage, ...args: any[]): boolean {
     return super.write(message, ...args)
   }
+
+  destroy(error?: Error): this {
+    if (error) {
+      this.write({ event: 'error', data: error.message })
+    }
+    this.end()
+    return this
+  }
 }
 
 function dataString(data: string | object): string {

Original file line number	Diff line number	Diff line change
`@@ -72,6 +72,14 @@ class SSEStream extends Transform {`
`72`	`72`	`write(message: SSEMessage, ...args: any[]): boolean {`
`73`	`73`	`return super.write(message, ...args)`
`74`	`74`	`}`
	`75`	`+`
	`76`	`+ destroy(error?: Error): this {`
	`77`	`+ if (error) {`
	`78`	`+ this.write({ event: 'error', data: error.message })`
	`79`	`+ }`
	`80`	`+ this.end()`
	`81`	`+ return this`
	`82`	`+ }`
`75`	`83`	`}`
`76`	`84`
`77`	`85`	`function dataString(data: string \| object): string {`