Reject if worker reported an error.

diff --git a/src/lib/worker-queue.ts b/src/lib/worker-queue.ts
index e2de7ebc0084a113064342c01e72cbc2a743eb5c..0fb18de85b3371b7cd17a62f02c44b8b860e3e8d 100644 (file)
--- a/src/lib/worker-queue.ts
+++ b/src/lib/worker-queue.ts
@@ -107,7 +107,11 @@ export class WorkerQueue {
                }
                const { resolve, reject } = this.#job
                try {
-                       resolve(results)
+                       if (results.error != null) {
+                               reject(results)
+                       } else {
+                               resolve(results)
+                       }
                } catch (err) {
                        reject(err)
                } finally {