You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Oct 31, 2018. It is now read-only.
Repository navigation
This repository was archived by the owner on Oct 31, 2018. It is now read-only.
Just wondering what's the best way to handle an error in a paused stream that is waiting for a promise to resolve. The example I have is something like the following case:
// Going to map some rows from a CSV readerfunctionmapRow(){returnfunction(data){// Yes, we want `this` in the context of the calling `through` function.varself=this;// Pausing the stream while we handle the promise.self.pause();somePromisaryService(data).then(function(){self.emit(data);self.resume();}).catch(function(err){//
621D
Ok, how do we deal with this???});}}aCsvReader().pipe(through(mapRow()));
Is there anything available in the context of through that I can use or do I need to introduce something external to catch any error in the promise?
Use self.emit('error', err)
You other self.emit(data) should be self.queue(data) BTW.
On Oct 5, 2015 12:47 PM, "Andrew Eddie" notifications@github.com wrote:
Just wondering what's the best way to handle an error in a paused stream
that is waiting for a promise to resolve. The example I have is something
like the following case:
// Going to map some rows from a CSV readerfunction mapRow() {
return function (data) {
// Yes, we want this in the context of the calling through function.
var self = this;
// Pausing the stream while we handle the promise.
self.pause();
somePromisaryService(data)
.then(function () {
self.emit(data);
self.resume();
})
.catch(function (err) {
// Ok, how do we deal with this???
});
}
}
aCsvReader()
.pipe(through(mapRow()));
Is there anything available in the context of through that I can use or
do I need to introduce something external to catch any error in the promise?
Thanks in advance.
—
Reply to this email directly or view it on GitHub #39.
Activity
dominictarr commentedon Oct 5, 2015
Use
self.emit('error', err)You other
self.emit(data)should beself.queue(data)BTW.On Oct 5, 2015 12:47 PM, "Andrew Eddie" notifications@github.com wrote: