Fix bugs

lib/AsyncObject.js

@@ -21,12 +21,12 @@ class AsyncObject {
             const id = this.fn(...this.args, (err, data) => {
                 if (err) reject(err);
 
-                this.controller = new AbortController();
                 resolve({ data, args: this.args });
             });
 
             signal.addEventListener("abort", () => {
                 if (id) clearTimeout(id);
+
                 reject(new Error("Operation is aborted..."));
             });
         });

lib/Queue.js

@@ -6,7 +6,7 @@ const EventEmitter = require("node:events");
 const AsyncObject = require("./AsyncObject");
 
 class Queue {
-    constructor(streams = 4, options) {
+    constructor(streams = 4, options = {}) {
         const {
             paused
         } = options;
@@ -16,15 +16,12 @@ class Queue {
         this.paused = (paused === undefined) ? true : paused;
 
         this.time = undefined;
-        this.finished = false;
 
         this.proccessed = new Map();
         this.waiting = [];
     }
 
     push(fn, ...args) {
-        if (this.finished) throw new Error("Queue is finished");
-
         const task = new AsyncObject(fn, ...args);
         this.waiting.push(task);
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@kol-oss/async-queue",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "description": "Async queue abstraction build on NodeJS",
   "main": "async-queue.js",
   "directories": {

test/3-promises.js → test/3-async.js

@@ -11,7 +11,7 @@ const queue = new Queue(2);
 // Set listeners callbacks
 queue
     .onResume(() => log("Execution started", "process"))
-    .onSuccess((data, args) => {
+    .onSuccess(async (data, args) => {
         log(`URL ${args} parsed:`, "success");
         log(data);
     })