summaryrefslogtreecommitdiffstats
path: root/devtools/client/shared/redux/middleware/task.js
diff options
context:
space:
mode:
Diffstat (limited to 'devtools/client/shared/redux/middleware/task.js')
-rw-r--r--devtools/client/shared/redux/middleware/task.js38
1 files changed, 38 insertions, 0 deletions
diff --git a/devtools/client/shared/redux/middleware/task.js b/devtools/client/shared/redux/middleware/task.js
new file mode 100644
index 0000000000..1ffb033589
--- /dev/null
+++ b/devtools/client/shared/redux/middleware/task.js
@@ -0,0 +1,38 @@
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+"use strict";
+
+loader.lazyRequireGetter(
+ this,
+ ["executeSoon", "isAsyncFunction", "reportException"],
+ "resource://devtools/shared/DevToolsUtils.js",
+ true
+);
+
+const ERROR_TYPE = (exports.ERROR_TYPE = "@@redux/middleware/task#error");
+
+/**
+ * A middleware that allows async thunks (async functions) to be dispatched.
+ * The middleware is called "task" for historical reasons. TODO: rename?
+ */
+
+function task({ dispatch, getState }) {
+ return next => action => {
+ if (isAsyncFunction(action)) {
+ return action({ dispatch, getState }).catch(
+ handleError.bind(null, dispatch)
+ );
+ }
+ return next(action);
+ };
+}
+
+function handleError(dispatch, error) {
+ executeSoon(() => {
+ reportException(ERROR_TYPE, error);
+ dispatch({ type: ERROR_TYPE, error });
+ });
+}
+
+exports.task = task;