|
1 | 1 | 'use strict';
|
2 |
| -var common = require('../common'); |
3 |
| -var assert = require('assert'); |
4 |
| -var fs = require('fs'); |
| 2 | +const common = require('../common'); |
| 3 | +const assert = require('assert'); |
| 4 | +const fs = require('fs'); |
5 | 5 |
|
6 |
| -var stream = fs.createReadStream(__filename, { |
| 6 | +const stream = fs.createReadStream(__filename, { |
7 | 7 | bufferSize: 64
|
8 | 8 | });
|
9 |
| -var err = new Error('BAM'); |
| 9 | +const err = new Error('BAM'); |
10 | 10 |
|
11 |
| -stream.on('error', common.mustCall(function errorHandler(err_) { |
12 |
| - console.error('error event'); |
13 |
| - process.nextTick(function() { |
14 |
| - assert.equal(stream.fd, null); |
15 |
| - assert.equal(err_, err); |
16 |
| - }); |
| 11 | +stream.on('error', common.mustCall((err_) => { |
| 12 | + process.nextTick(common.mustCall(() => { |
| 13 | + assert.strictEqual(stream.fd, null); |
| 14 | + assert.strictEqual(err_, err); |
| 15 | + })); |
17 | 16 | }));
|
18 | 17 |
|
19 |
| -fs.close = common.mustCall(function(fd_, cb) { |
20 |
| - assert.equal(fd_, stream.fd); |
| 18 | +fs.close = common.mustCall((fd_, cb) => { |
| 19 | + assert.strictEqual(fd_, stream.fd); |
21 | 20 | process.nextTick(cb);
|
22 | 21 | });
|
23 | 22 |
|
24 |
| -var read = fs.read; |
| 23 | +const read = fs.read; |
25 | 24 | fs.read = function() {
|
26 | 25 | // first time is ok.
|
27 | 26 | read.apply(fs, arguments);
|
28 | 27 | // then it breaks
|
29 |
| - fs.read = function() { |
30 |
| - var cb = arguments[arguments.length - 1]; |
31 |
| - process.nextTick(function() { |
| 28 | + fs.read = common.mustCall(function() { |
| 29 | + const cb = arguments[arguments.length - 1]; |
| 30 | + process.nextTick(() => { |
32 | 31 | cb(err);
|
33 | 32 | });
|
34 | 33 | // and should not be called again!
|
35 |
| - fs.read = function() { |
| 34 | + fs.read = () => { |
36 | 35 | throw new Error('BOOM!');
|
37 | 36 | };
|
38 |
| - }; |
| 37 | + }); |
39 | 38 | };
|
40 | 39 |
|
41 |
| -stream.on('data', function(buf) { |
42 |
| - stream.on('data', common.fail); // no more 'data' events should follow |
| 40 | +stream.on('data', (buf) => { |
| 41 | + stream.on('data', () => common.fail("no more 'data' events should follow")); |
43 | 42 | });
|
0 commit comments