how do you handle errors here #6

Activity

1. dominictarr commented on Aug 21, 2016

   

   dominictarr

   on Aug 21, 2016

   Member

   More actions

   pushable.end takes an argument, https://github.com/pull-stream/pull-pushable/blob/master/index.js#L28 that can be the error,

   but really, it looks like you should use stream-to-pull-stream instead of pull-pushable

   return toPull.source(emitter)
2. nichoth commented on Aug 21, 2016

   

   nichoth

   on Aug 21, 2016

   Last edited by nichoth

   Author

   More actions

   Ah ha. So pushable.end() can be the end event, and pushable.end(error) can be the error event. Thanks

   function createMyStream (emitter) {
       var pushable = Pushable(function onEnd (err) {
           if (err) console.log(err)
           emitter.removeAllListeners()
       })
       emitter.on('data', (data) => pushable.push(data))
       emitter.on('end', () => pushable.end())
       emitter.on('error', (err) => pushable.end(err))
       return pushable
   }