Skip to content

Commit f8b345e

Browse files
resolve streamAppendToFile when read stream emits 'end'
1 parent 0c152e6 commit f8b345e

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

src/libraries/Executor.ts

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -375,9 +375,13 @@ class Executor {
375375
reject(e)
376376
})
377377

378-
rs.pipe(ws)
378+
rs.on('end', () => {
379+
rs.close();
380+
ws.close();
381+
resolve()
382+
})
379383

380-
ws.on('finish', () => resolve)
384+
rs.pipe(ws)
381385
})
382386
}
383387

0 commit comments

Comments
 (0)