handle error event

nodejitsu · Mar 23, 2013 · 777ee25 · 777ee25
1 parent 7891490
commit 777ee25
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/godot/reactor/redis.js b/lib/godot/reactor/redis.js
@@ -67,8 +67,8 @@ Redis.prototype.write = function (data) {
   }
 
   this.redisFn(this.client, data, function (err, data) {
-    if (!err) {
-      self.emit('data', data);
-    }
+    return err
+      ? self.emit('error', err)
+      : self.emit('data', data);
   });
 };