not sync if watch error

vincent-zhao · Oct 29, 2012 · c3cb2d7 · c3cb2d7
1 parent 69aadef
commit c3cb2d7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/service.js b/lib/service.js
@@ -78,8 +78,8 @@ Subscribe.prototype.start = function () {
   sync(function () {
     _self.store.watch(_self.root, _self.options.timeout, function (error, rev) {
       if (error) {
-        _self.emit('error', error);
-      }
+        return _self.emit('error', error);
+      } 
       if (rev) {
         sync();
       }