|
1 |
| -var spies = require('./spy'); |
2 |
| -var chmodSpy = spies.chmodSpy; |
3 |
| -var statSpy = spies.statSpy; |
4 |
| - |
5 | 1 | var vfs = require('../');
|
6 | 2 |
|
7 | 3 | var path = require('path');
|
@@ -53,21 +49,36 @@ describe('source stream', function() {
|
53 | 49 | });
|
54 | 50 | });
|
55 | 51 |
|
| 52 | + it('should error on file not existing', function(done) { |
| 53 | + var stream = vfs.src('./fixtures/noexist.coffee'); |
| 54 | + stream.on('error', function(err){ |
| 55 | + should.exist(err); |
| 56 | + done(); |
| 57 | + }); |
| 58 | + }); |
| 59 | + |
56 | 60 | it('should pass through writes', function(done) {
|
57 | 61 | var expectedPath = path.join(__dirname, './fixtures/test.coffee');
|
58 | 62 | var expectedContent = fs.readFileSync(expectedPath);
|
59 |
| - |
| 63 | + var files = []; |
60 | 64 | var expectedFile = new File({
|
61 | 65 | base: __dirname,
|
62 | 66 | cwd: __dirname,
|
63 | 67 | path: expectedPath,
|
64 |
| - contents: expectedContent |
| 68 | + contents: expectedContent, |
| 69 | + stat: fs.lstatSync(expectedPath) |
65 | 70 | });
|
66 | 71 |
|
67 |
| - var stream = vfs.src('./fixtures/noexist.coffee'); |
| 72 | + var stream = vfs.src(expectedPath, {cwd: __dirname, base: __dirname}); |
68 | 73 | stream.on('data', function(file){
|
69 |
| - file.should.equal(expectedFile); |
70 |
| - bufEqual(file.contents, expectedContent).should.equal(true); |
| 74 | + files.push(file); |
| 75 | + }); |
| 76 | + stream.once('end', function(){ |
| 77 | + files.length.should.equal(2); |
| 78 | + files[0].should.eql(expectedFile); |
| 79 | + bufEqual(files[0].contents, expectedContent).should.equal(true); |
| 80 | + files[1].should.eql(expectedFile); |
| 81 | + bufEqual(files[1].contents, expectedContent).should.equal(true); |
71 | 82 | done();
|
72 | 83 | });
|
73 | 84 | stream.write(expectedFile);
|
|
0 commit comments