123456789101112131415 |
- 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 {};
|