1 var common
= require('../common');
2 var assert
= common
.assert
;
3 var CombinedStream
= common
.CombinedStream
;
4 var fs
= require('fs');
6 var FILE1
= common
.dir
.fixture
+ '/file1.txt';
7 var FILE2
= common
.dir
.fixture
+ '/file2.txt';
8 var EXPECTED
= fs
.readFileSync(FILE1
) + fs
.readFileSync(FILE2
);
10 (function testDelayedStreams() {
11 var combinedStream
= CombinedStream
.create();
12 combinedStream
.append(function(next
) {
13 next(fs
.createReadStream(FILE1
));
15 combinedStream
.append(function(next
) {
16 next(fs
.createReadStream(FILE2
));
19 var tmpFile
= common
.dir
.tmp
+ '/combined.txt';
20 var dest
= fs
.createWriteStream(tmpFile
);
21 combinedStream
.pipe(dest
);
23 dest
.on('end', function() {
24 var written
= fs
.readFileSync(tmpFile
, 'utf8');
25 assert
.strictEqual(written
, EXPECTED
);