1 files changed, 49 insertions, 0 deletions
diff --git a/devtools/client/debugger/src/utils/worker.js b/devtools/client/debugger/src/utils/worker.js
new file mode 100644
index 0000000000..8cd7071466
--- /dev/null
+++ b/devtools/client/debugger/src/utils/worker.js
@@ -0,0 +1,49 @@
+/* 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/>. */
+
+let msgId = 1;
+/**
+ * @memberof utils/utils
+ * @static
+ */
+function workerTask(worker, method) {
+  return function (...args) {
+    return new Promise((resolve, reject) => {
+      const id = msgId++;
+      worker.postMessage({ id, method, args });
+
+      const listener = ({ data: result }) => {
+        if (result.id !== id) {
+          return;
+        }
+
+        worker.removeEventListener("message", listener);
+        if (result.error) {
+          reject(result.error);
+        } else {
+          resolve(result.response);
+        }
+      };
+
+      worker.addEventListener("message", listener);
+    });
+  };
+}
+
+function workerHandler(publicInterface) {
+  return function onTask(msg) {
+    const { id, method, args } = msg.data;
+    const response = publicInterface[method].apply(null, args);
+
+    if (response instanceof Promise) {
+      response
+        .then(val => self.postMessage({ id, response: val }))
+        .catch(error => self.postMessage({ id, error }));
+    } else {
+      self.postMessage({ id, response });
+    }
+  };
+}
+
+export { workerTask, workerHandler };