Catch errors in promise resolved with stream concatenation in node js

Question

I need to catch errors thrown inside a stream event in promise resolution. Something like

function foo(){
 return new Promise((resolve,reject) => {
  resolve(res.pipe(transfomrStream).pipe(through2.obj(function(obj, enc, callback) {
    on('end', ()=>{ 
        await httpReq(...)
          .then((crudRes) => assert.strictEqual(somerthing))
      })
     )
   })
 })
}

how could i catch assert failure? I've tried to return error inside the last pipe() or in function calling but i only get unhandled promise rejection

score 0 · Answer 1 · answered Dec 20 '18 at 10:40

If you surround your code with a try catch you can at least see what your error is:

function foo(){
try{
 return new Promise((resolve,reject) => {
  resolve(res.pipe(transfomrStream).pipe(through2.obj(function(obj, enc, callback) {
    on('end', ()=>{ 
        await httpReq(...)
          .then((crudRes) => assert.strictEqual(somerthing))
      })
     )
   })
 })
 }
 catch(e) {
  console.log(e)
  reject()
}
}

Also, if you have an await you cannot use .then(). And you will have to make your function async if you're doing await.

Catch errors in promise resolved with stream concatenation in node js

1 Answers1