FM / providers

/var/www/cobraambalaj/node_modules/@nodelib/fs.walk/src/providers/

/var/www/cobraambalaj/node_modules/@nodelib/fs.walk/src/providers

Name	Size	Mode	Actions
async.spec.ts	1632	0644	edit dl rm
async.ts	1152	0644	edit dl rm
index.ts	171	0644	edit dl rm
stream.spec.ts	2441	0644	edit dl rm
stream.ts	829	0644	edit dl rm
sync.spec.ts	975	0644	edit dl rm
sync.ts	385	0644	edit dl rm

Edit: /var/www/cobraambalaj/node_modules/@nodelib/fs.walk/src/providers/async.ts (1152B)

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);
}

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 = 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); }