Comparing version 1.10.0 to 1.10.1
@@ -10,4 +10,4 @@ declare function fastq<C, T = any, R = any>(context: C, worker: fastq.worker<C, T, R>, concurrency: number): fastq.queue<T, R> | ||
interface queue<T = any, R = any> { | ||
push(task: T, done: done<R>): void | ||
unshift(task: T, done: done<R>): void | ||
push(task: T, done?: done<R>): void | ||
unshift(task: T, done?: done<R>): void | ||
pause(): any | ||
@@ -14,0 +14,0 @@ resume(): any |
{ | ||
"name": "fastq", | ||
"version": "1.10.0", | ||
"version": "1.10.1", | ||
"description": "Fast, in memory work queue", | ||
@@ -5,0 +5,0 @@ "main": "queue.js", |
@@ -12,2 +12,4 @@ import * as fastq from '../' | ||
queue.push('push without cb') | ||
queue.concurrency | ||
@@ -40,2 +42,4 @@ | ||
queue.unshift('unshift without cb') | ||
function worker(task: any, cb: fastq.done) { | ||
@@ -42,0 +46,0 @@ cb(null, 'hello ' + task) |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
27489
738