queue.d.ts 578 B

123456789101112131415
  1. import { WalkerState } from "../types";
  2. type OnQueueEmptyCallback = (error: Error | null, output: WalkerState) => void;
  3. /**
  4. * This is a custom stateless queue to track concurrent async fs calls.
  5. * It increments a counter whenever a call is queued and decrements it
  6. * as soon as it completes. When the counter hits 0, it calls onQueueEmpty.
  7. */
  8. export declare class Queue {
  9. private readonly onQueueEmpty;
  10. private count;
  11. constructor(onQueueEmpty: OnQueueEmptyCallback);
  12. enqueue(): void;
  13. dequeue(error: Error | null, output: WalkerState): void;
  14. }
  15. export {};