GithubBackup/geekgeekrun
1
0
Fork 0
mirror of https://github.com/geekgeekrun/geekgeekrun.git synced 2026-09-07 00:17:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

once pipe for process communication get bad, exit process immediately

Browse Source
This commit is contained in:
geekgeekrun
2024-04-05 17:19:00 +08:00
parent 3a31f7d186
commit fdf9081a8f
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/ui/src/main/flow/utils/pipe.ts
+9 -2
View File
@@ -1,5 +1,6 @@
import * as fs from 'fs' import * as fs from 'fs'
import { type Stream } from 'stream' import { type Stream } from 'stream'
import { app } from 'electron'
const pipeSet = new WeakSet<Stream>() const pipeSet = new WeakSet<Stream>()
export const pipeWriteRegardlessError = async ( export const pipeWriteRegardlessError = async (
@@ -10,8 +11,14 @@ export const pipeWriteRegardlessError = async (
if (pipe && !pipeSet.has(pipe)) { if (pipe && !pipeSet.has(pipe)) {
pipeSet.add(pipe) pipeSet.add(pipe)
pipe.on('error', (error) => { pipe.on('error', (error) => {
console.log('pipe.write Error', error) void error
}) })
} }
return pipe?.write(chunk, option, () => {}) return pipe?.write(chunk, option, (error) => {
if (error) {
console.log('pipe.write Error', error)
app.exit(1)
process.exit(1)
}
})
} }