2 files changed, 88 insertions, 0 deletions
diff --git a/src/web/js/dispatcher/JarrDispatcher.js b/src/web/js/dispatcher/JarrDispatcher.js
new file mode 100644
index 00000000..56da186f
--- /dev/null
+++ b/src/web/js/dispatcher/JarrDispatcher.js
@@ -0,0 +1,16 @@
+/*
+ * Copyright (c) 2014-2015, Facebook, Inc.
+ * All rights reserved.
+ *
+ * This source code is licensed under the BSD-style license found in the
+ * LICENSE file in the root directory of this source tree. An additional grant
+ * of patent rights can be found in the PATENTS file in the same directory.
+ *
+ * AppDispatcher
+ *
+ * A singleton that operates as the central hub for application updates.
+ */
+
+var Dispatcher = require('flux').Dispatcher;
+
+module.exports = new Dispatcher();
diff --git a/src/web/js/dispatcher/__tests__/AppDispatcher-test.js b/src/web/js/dispatcher/__tests__/AppDispatcher-test.js
new file mode 100644
index 00000000..d3a35fc5
--- /dev/null
+++ b/src/web/js/dispatcher/__tests__/AppDispatcher-test.js
@@ -0,0 +1,72 @@
+"use strict";
+
+jest.autoMockOff();
+
+describe('AppDispatcher', function() {
+  var AppDispatcher;
+
+  beforeEach(function() {
+    AppDispatcher = require('../AppDispatcher.js');
+  });
+
+  it('sends actions to subscribers', function() {
+    var listener = jest.genMockFunction();
+    AppDispatcher.register(listener);
+
+    var payload = {};
+    AppDispatcher.dispatch(payload);
+    expect(listener.mock.calls.length).toBe(1);
+    expect(listener.mock.calls[0][0]).toBe(payload);
+  });
+
+  it('waits with chained dependencies properly', function() {
+    var payload = {};
+
+    var listener1Done = false;
+    var listener1 = function(pl) {
+      AppDispatcher.waitFor([index2, index4]);
+      // Second, third, and fourth listeners should have now been called
+      expect(listener2Done).toBe(true);
+      expect(listener3Done).toBe(true);
+      expect(listener4Done).toBe(true);
+      listener1Done = true;
+    };
+    var index1 = AppDispatcher.register(listener1);
+
+    var listener2Done = false;
+    var listener2 = function(pl) {
+      AppDispatcher.waitFor([index3]);
+      expect(listener3Done).toBe(true);
+      listener2Done = true;
+    };
+    var index2 = AppDispatcher.register(listener2);
+
+    var listener3Done = false;
+    var listener3 = function(pl) {
+      listener3Done = true;
+    };
+    var index3 = AppDispatcher.register(listener3);
+
+    var listener4Done = false;
+    var listener4 = function(pl) {
+      AppDispatcher.waitFor([index3]);
+      expect(listener3Done).toBe(true);
+      listener4Done = true;
+    };
+    var index4 = AppDispatcher.register(listener4);
+
+    runs(function() {
+      AppDispatcher.dispatch(payload);
+    });
+
+    waitsFor(function() {
+      return listener1Done;
+    }, "Not all subscribers were properly called", 500);
+
+    runs(function() {
+      expect(listener1Done).toBe(true);
+      expect(listener2Done).toBe(true);
+      expect(listener3Done).toBe(true);
+    });
+  });
+});