Improve stream error handling

ehmicky · May 15, 2019 · 4ceb0a8 · 4ceb0a8
1 parent ecde8d2
commit 4ceb0a8
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/stream.js b/src/stream.js
@@ -89,7 +89,12 @@ const replaceResult = function({ file, input, opts }) {
 }
 
 const streamResult = function({ file, input, opts, opts: { from } }) {
-  const { [from]: result } = streamCommand(input, opts)
+  const execaResult = streamCommand(input, opts)
+  const { [from]: result } = execaResult
+
+  // Make stream fail if the command fails
+  execaResult.catch(error => result.emit('error', error))
+
   // eslint-disable-next-line no-param-reassign, fp/no-mutation
   file.contents = result
 }