ssube
/
salty-dog
1
0
Fork 0
Code

cover stream error handling

This commit is contained in:
ssube 2019-11-15 17:45:23 -06:00 committed by Sean Sube
parent 0ba6382253
commit b818aa66d4
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
test/TestSource.ts
View File

@ -1,6 +1,7 @@
import { expect } from 'chai'; import { expect } from 'chai';
import mockFs from 'mock-fs'; import mockFs from 'mock-fs';
import { spy } from 'sinon'; import { BaseError } from 'noicejs';
import { spy, stub } from 'sinon';
import { PassThrough } from 'stream'; import { PassThrough } from 'stream';
import { readSource, writeSource } from '../src/source'; import { readSource, writeSource } from '../src/source';
@ -31,6 +32,14 @@ describeLeaks('load source helper', async () => {
expect(source).to.equal(TEST_STRING); expect(source).to.equal(TEST_STRING);
}); });
it('should handle errors reading from stdin', async () => {
const pt = new PassThrough();
const futureSource = readSource('-', pt);
pt.emit('error', new BaseError('terribad!'));
return expect(futureSource).to.eventually.be.rejectedWith(BaseError);
});
}); });
describeLeaks('write source helper', async () => { describeLeaks('write source helper', async () => {
@ -56,4 +65,11 @@ describeLeaks('write source helper', async () => {
expect(writeSpy).to.have.been.calledWith(TEST_STRING); expect(writeSpy).to.have.been.calledWith(TEST_STRING);
}); });
it('should handle errors writing to stdout', async () => {
const pt = new PassThrough();
stub(pt, 'write').yields(new BaseError('terribad!'));
return expect(writeSource('-', 'test', pt)).to.eventually.be.rejectedWith(BaseError);
});
}); });