FM / providers

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

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

Name	Size	Mode	Actions
async.d.ts	513	0644	edit dl rm
async.d.ts.map	578	0644	edit dl rm
async.js	936	0644	edit dl rm
async.spec.d.ts	52	0644	edit dl rm
async.spec.d.ts.map	127	0644	edit dl rm
async.spec.js	1789	0644	edit dl rm
index.d.ts	206	0644	edit dl rm
index.d.ts.map	259	0644	edit dl rm
index.js	397	0644	edit dl rm
stream.d.ts	456	0644	edit dl rm
stream.d.ts.map	480	0644	edit dl rm
stream.js	1055	0644	edit dl rm
stream.spec.d.ts	53	0644	edit dl rm
stream.spec.d.ts.map	129	0644	edit dl rm
stream.spec.js	2651	0644	edit dl rm
sync.d.ts	372	0644	edit dl rm
sync.d.ts.map	432	0644	edit dl rm
sync.js	421	0644	edit dl rm
sync.spec.d.ts	51	0644	edit dl rm
sync.spec.d.ts.map	125	0644	edit dl rm
sync.spec.js	1017	0644	edit dl rm

Edit: /var/www/cobraambalaj/node_modules/@nodelib/fs.walk/out/providers/stream.spec.js (2651B)

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const assert = require("assert");
const stream_1 = require("stream");
const sinon = require("sinon");
const settings_1 = require("../settings");
const tests = require("../tests");
const stream_2 = require("./stream");
class TestProvider extends stream_2.default {
    constructor(_root, _settings = new settings_1.default()) {
        super(_root, _settings);
        this._reader = new tests.TestAsyncReader();
        this._stream.emit = sinon.stub();
        this._stream.push = sinon.stub();
    }
    get reader() {
        return this._reader;
    }
    get stream() {
        return this._stream;
    }
}
describe('Providers → Stream', () => {
    describe('.read', () => {
        it('should return stream', () => {
            const provider = new TestProvider('directory');
            const stream = provider.read();
            assert.ok(stream instanceof stream_1.Readable);
        });
        it('should call reader function with correct set of arguments', () => {
            const provider = new TestProvider('directory');
            provider.read();
            assert.ok(provider.reader.read.called);
        });
        it('should re-emit the "error" event from reader', () => {
            const provider = new TestProvider('directory');
            provider.reader.onError.yields(tests.EPERM_ERRNO);
            provider.read();
            assert.deepStrictEqual(provider.stream.emit.args, [['error', tests.EPERM_ERRNO]]);
        });
        it('should call the "push" method with entry value for the "entry" event from reader', () => {
            const provider = new TestProvider('directory');
            const fakeEntry = tests.buildFakeFileEntry();
            provider.reader.onEntry.yields(fakeEntry);
            provider.read();
            assert.deepStrictEqual(provider.stream.push.args, [[fakeEntry]]);
        });
        it('should call the "push" method with "null" value for the "end" event from reader', () => {
            const provider = new TestProvider('directory');
            provider.reader.onEnd.yields();
            provider.read();
            assert.deepStrictEqual(provider.stream.push.args, [[null]]);
        });
        it('should do not destroy reader when it is already destroyed', () => {
            const provider = new TestProvider('directory');
            const stream = provider.read();
            stream.destroy();
            assert.ok(stream.destroyed);
            assert.doesNotThrow(() => stream.destroy());
        });
    });
});

"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); const assert = require("assert"); const stream_1 = require("stream"); const sinon = require("sinon"); const settings_1 = require("../settings"); const tests = require("../tests"); const stream_2 = require("./stream"); class TestProvider extends stream_2.default { constructor(_root, _settings = new settings_1.default()) { super(_root, _settings); this._reader = new tests.TestAsyncReader(); this._stream.emit = sinon.stub(); this._stream.push = sinon.stub(); } get reader() { return this._reader; } get stream() { return this._stream; } } describe('Providers → Stream', () => { describe('.read', () => { it('should return stream', () => { const provider = new TestProvider('directory'); const stream = provider.read(); assert.ok(stream instanceof stream_1.Readable); }); it('should call reader function with correct set of arguments', () => { const provider = new TestProvider('directory'); provider.read(); assert.ok(provider.reader.read.called); }); it('should re-emit the "error" event from reader', () => { const provider = new TestProvider('directory'); provider.reader.onError.yields(tests.EPERM_ERRNO); provider.read(); assert.deepStrictEqual(provider.stream.emit.args, [['error', tests.EPERM_ERRNO]]); }); it('should call the "push" method with entry value for the "entry" event from reader', () => { const provider = new TestProvider('directory'); const fakeEntry = tests.buildFakeFileEntry(); provider.reader.onEntry.yields(fakeEntry); provider.read(); assert.deepStrictEqual(provider.stream.push.args, [[fakeEntry]]); }); it('should call the "push" method with "null" value for the "end" event from reader', () => { const provider = new TestProvider('directory'); provider.reader.onEnd.yields(); provider.read(); assert.deepStrictEqual(provider.stream.push.args, [[null]]); }); it('should do not destroy reader when it is already destroyed', () => { const provider = new TestProvider('directory'); const stream = provider.read(); stream.destroy(); assert.ok(stream.destroyed); assert.doesNotThrow(() => stream.destroy()); }); }); });