Prevent cancelled queues from processing beyond the point of cancellation.

Author: coreybutler

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@ngnjs/queue",
-  "version": "1.0.0-alpha.6",
+  "version": "1.0.0-alpha.7",
   "description": "A lightweight NGN queue (taskrunner).",
   "type": "module",
   "main": "src/index.js",

src/item.js

@@ -110,7 +110,7 @@ export default class Item extends NGN.EventEmitter {
     // If the item is part of a queue handled by a runner,
     // respect the state of the runner.
     if (this.parent && this.parent.parent) {
-      if (this.parent.parent.continue) {
+      if (!this.parent.parent.continue) {
         return
       }
     }

src/runner.js

@@ -41,7 +41,7 @@ export default class Queue extends EventEmitter {
           this.emit('status.change', { old, current: value })
         }
       }),
-      continue: NGN.get(() => this.#status === 'aborting'),
+      continue: NGN.get(() => this.#status !== 'aborting' && this.#status !== 'cancelled'),
       moduleVersion: NGN.hiddenconstant('<#REPLACE_VERSION#>')
     })
 
@@ -94,6 +94,10 @@ export default class Queue extends EventEmitter {
     return this.#cancelled
   }
 
+  get status () {
+    return this.#status
+  }
+
   reset () {
     this.#queue.afterOnce('reset', this.#queue.size, () => {
       this.#cancelled = false