Add queue.remove(testFn) (#56)

* Add queue.remove(testFn) Add queue.remove(testFn) to Neo-Async v2.4.0 This function is from Async v2.5.0 * Add queue.remove(testFn) Add queue.remove(testFn) to Neo-Async v2.4.0 This function is from Async v2.5.0 * test for queue.remove() test for queue.remove() * Add queue.remove() Add queue.remove() * Add queue.remove() Add queue.remove()
suguru03 · Oct 3, 2017 · c5e7d6f · c5e7d6f
1 parent 29c32f8
commit c5e7d6f
Show file tree

Hide file tree

Showing 5 changed files with 231 additions and 152 deletions.
diff --git a/dist/async.js b/dist/async.js
@@ -7783,6 +7783,18 @@
     }
     return tasks;
   };
+
+  DLL.prototype.remove = function(testFn) {
+    var curr = this.head;
+    while(!!curr) {
+        var next = curr.next;
+        if (testFn(curr)) {
+            this._removeLink(curr);
+        }
+        curr = next;
+    }
+    return this;
+  };
 
   /**
    * @private
@@ -7813,6 +7825,7 @@
       push: push,
       kill: kill,
       unshift: unshift,
+	  remove: remove,
       process: isQueue ? runQueue : runCargo,
       length: getLength,
       running: running,
@@ -7988,6 +8001,10 @@
       var count = q.concurrency < q._tasks.length ? q.concurrency : q._tasks.length;
       timesSync(count, _resume);
     }
+
+	function remove(testFn) {
+		q._tasks.remove(testFn);
+	}
   }
 
   /**