FM / fastq

/var/www/cobraambalaj/node_modules/fastq/

/var/www/cobraambalaj/node_modules/fastq

Name	Size	Mode	Actions
.github/	-	0755	rm
test/	-	0755	rm
bench.js	1175	0644	edit dl rm
example.js	209	0644	edit dl rm
index.d.ts	1327	0644	edit dl rm
LICENSE	765	0644	edit dl rm
package.json	2086	0644	edit dl rm
queue.js	4920	0644	edit dl rm
README.md	6961	0644	edit dl rm

Edit: /var/www/cobraambalaj/node_modules/fastq/index.d.ts (1327B)

declare function fastq<C, T = any, R = any>(context: C, worker: fastq.worker<C, T, R>, concurrency: number): fastq.queue<T, R>
declare function fastq<C, T = any, R = any>(worker: fastq.worker<C, T, R>, concurrency: number): fastq.queue<T, R>

declare namespace fastq {
  type worker<C, T = any, R = any> = (this: C, task: T, cb: fastq.done<R>) => void
  type asyncWorker<C, T = any, R = any> = (this: C, task: T) => Promise<R>
  type done<R = any> = (err: Error | null, result?: R) => void
  type errorHandler<T = any> = (err: Error, task: T) => void

interface queue<T = any, R = any> {
    push(task: T, done?: done<R>): void
    unshift(task: T, done?: done<R>): void
    pause(): any
    resume(): any
    idle(): boolean
    length(): number
    getQueue(): T[]
    kill(): any
    killAndDrain(): any
    error(handler: errorHandler): void
    concurrency: number
    drain(): any
    empty: () => void
    saturated: () => void
  }

interface queueAsPromised<T = any, R = any> extends queue<T, R> {
    push(task: T): Promise<R>
  }

function promise<C, T = any, R = any>(context: C, worker: fastq.asyncWorker<C, T, R>, concurrency: number): fastq.queueAsPromised<T, R>
  function promise<C, T = any, R = any>(worker: fastq.asyncWorker<C, T, R>, concurrency: number): fastq.queueAsPromised<T, R>
}

export = fastq

declare function fastq(context: C, worker: fastq.worker, concurrency: number): fastq.queue declare function fastq(worker: fastq.worker, concurrency: number): fastq.queue declare namespace fastq { type worker = (this: C, task: T, cb: fastq.done) => void type asyncWorker = (this: C, task: T) => Promise type done = (err: Error | null, result?: R) => void type errorHandler = (err: Error, task: T) => void interface queue { push(task: T, done?: done): void unshift(task: T, done?: done): void pause(): any resume(): any idle(): boolean length(): number getQueue(): T[] kill(): any killAndDrain(): any error(handler: errorHandler): void concurrency: number drain(): any empty: () => void saturated: () => void } interface queueAsPromised extends queue { push(task: T): Promise } function promise(context: C, worker: fastq.asyncWorker, concurrency: number): fastq.queueAsPromised function promise(worker: fastq.asyncWorker, concurrency: number): fastq.queueAsPromised } export = fastq