Sha256: bfb95b1c3a8aed0d7a33cf3591137aefd895d384c7b639f88481e04958510881
Contents?: true
Size: 578 Bytes
Versions: 26
Compression:
Stored size: 578 Bytes
Contents
import { WalkerState } from "../types";
type OnQueueEmptyCallback = (error: Error | null, output: WalkerState) => void;
/**
* This is a custom stateless queue to track concurrent async fs calls.
* It increments a counter whenever a call is queued and decrements it
* as soon as it completes. When the counter hits 0, it calls onQueueEmpty.
*/
export declare class Queue {
private readonly onQueueEmpty;
private count;
constructor(onQueueEmpty: OnQueueEmptyCallback);
enqueue(): void;
dequeue(error: Error | null, output: WalkerState): void;
}
export {};
Version data entries
26 entries across 26 versions & 1 rubygems