Sha256: 54d20ad1562291c2c850de884f9b5c478f86a44b8466762bb7a80b7ec8223689
Contents?: true
Size: 646 Bytes
Versions: 23
Compression:
Stored size: 646 Bytes
Contents
declare function fastq<T>(context: T, worker: fastq.worker<T>, concurrency: number): fastq.queue
declare function fastq<T>(worker: fastq.worker<T>, concurrency: number): fastq.queue
declare namespace fastq {
type worker<T> = (this: T, arg: any, cb: () => void) => void
type done = (err: Error, result: any) => void
interface queue {
push(task: any, done: done): void
unshift(task: any, done: done): void
pause(): any
resume(): any
idle(): boolean
length(): number
kill(): any
killAndDrain(): any
concurrency: number
drain(): any
empty: () => void
saturated: () => void
}
}
export = fastq
Version data entries
23 entries across 23 versions & 1 rubygems