Always dispatch for all paths (instead of skipping)

1 files changed, 0 insertions, 4 deletions

diff --git a/zake/fake_client.py b/zake/fake_client.py
index 8597c59..660d061 100644
--- a/zake/fake_client.py
+++ b/zake/fake_client.py
@@ -362,15 +362,11 @@ class FakeClient(object):
                                self._data_watches_lock)
 
     def _fire_watches(self, paths, event, watch_source, watch_mutate_lock):
-        dispatched = set()
         for path in reversed(sorted(paths)):
-            if path in dispatched:
-                continue
             with watch_mutate_lock:
                 watches = list(watch_source.pop(path, []))
             for w in watches:
                 self.handler.dispatch_callback(utils.make_cb(w, [event]))
-            dispatched.add(path)
 
     def transaction(self):
         return FakeTransactionRequest(self)