Gecko [ fernandoquevedodop.com ]

Name	Size	Permission
async.spec.ts	1.59 KB	-rw-r--r--
async.ts	1.13 KB	-rw-r--r--
index.ts	171 B	-rw-r--r--
stream.spec.ts	2.38 KB	-rw-r--r--
stream.ts	829 B	-rw-r--r--
sync.spec.ts	975 B	-rw-r--r--
sync.ts	385 B	-rw-r--r--

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