[fix] add an error listeners to the reactors in the pipe chain

nodejitsu · May 26, 2013 · e55229c · e55229c
1 parent 65ece42
commit e55229c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/godot/reactor/reactor.js b/lib/godot/reactor/reactor.js
@@ -64,8 +64,9 @@ Reactor.prototype.createStream = function (source) {
   }
 
   return this.reactors.reduce(function (last, nextOptions) {
+    last.on('error', function (err) { console.log(err) });
     return last.pipe(
       wrapStream(nextOptions.Factory, nextOptions.args || [])
     );
   }, source);
-};
+};