webhook-action/node_modules/@nodelib/fs.walk/src/providers/async.ts

import AsyncReader from '../readers/async';
import Settings from '../settings';
import { Entry, Errno } from '../types';

type FailureCallback = (err: Errno) => void;
type SuccessCallback = (err: null, entries: Entry[]) => void;

export type AsyncCallback = (err: Errno, entries: Entry[]) => void;

export default class AsyncProvider {
	protected readonly _reader: AsyncReader = new AsyncReader(this._root, this._settings);

	private readonly _storage: Set<Entry> = new Set();

	constructor(private readonly _root: string, private readonly _settings: Settings) { }

	public read(callback: AsyncCallback): void {
		this._reader.onError((error) => {
			callFailureCallback(callback, error);
		});

		this._reader.onEntry((entry: Entry) => {
			this._storage.add(entry);
		});

		this._reader.onEnd(() => {
			callSuccessCallback(callback, [...this._storage]);
		});

		this._reader.read();
	}
}

function callFailureCallback(callback: AsyncCallback, error: Errno): void {
	(callback as FailureCallback)(error);
}

function callSuccessCallback(callback: AsyncCallback, entries: Entry[]): void {
	(callback as unknown as SuccessCallback)(null, entries);
}