333

schangxiang@126.com

2025-09-19 18966e02fb573c7e2bb0c6426ed792b38b910940

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
var stream = require('../lib/lazystream');
var fs = require('fs');
var tmpDir = 'test/tmp/';
var readFile = 'test/data.md';
var writeFile = tmpDir + 'data.md';
 
exports.fs = {
  readwrite: function(test) {
    var readfd, writefd;
 
    var readable = new stream.Readable(function() {
       return fs.createReadStream(readFile)
        .on('open', function(fd) {
          readfd = fd;
        })
        .on('close', function() {
           readfd = undefined;
           step();
        });
    });
 
    var writable = new stream.Writable(function() {
      return fs.createWriteStream(writeFile)
        .on('open', function(fd) {
          writefd = fd;
        })
        .on('close', function() {
          writefd = undefined;
           step();
        });
    });
 
    test.expect(3);
 
    test.equal(readfd, undefined, 'Input file should not be opened until read');
    test.equal(writefd, undefined, 'Output file should not be opened until write');
 
    if (!fs.existsSync(tmpDir)) {
      fs.mkdirSync(tmpDir);
    }
    if (fs.existsSync(writeFile)) {
      fs.unlinkSync(writeFile);
    }
 
    readable.on('end', function() { step(); });
    writable.on('end', function() { step(); });
 
    var steps = 0;
    function step() {
      steps += 1;
      if (steps == 4) {
        var input = fs.readFileSync(readFile);
        var output = fs.readFileSync(writeFile);
 
        test.ok(input >= output && input <= output, 'Should be equal');
 
        fs.unlinkSync(writeFile);
        fs.rmdirSync(tmpDir);
 
        test.done();
      }
    };
 
    readable.pipe(writable);
  }
};