in src/master.ts [18:30]
function runGlobs(files: string[], ignore: Ignore) {
return new Observable<string>((subscriber) => {
const stream = globStream(files, { nodir: true });
stream.addListener('data', (data) => {
if (!ignore.ignores(relative(data.cwd, data.path))) {
subscriber.next(data);
}
});
stream.addListener('error', (err) => subscriber.error(err));
stream.addListener('finish', () => subscriber.complete());
stream.resume();
});
}