diff options
Diffstat (limited to 'test/parallel/test-stream-unpipe-event.js')
| -rw-r--r-- | test/parallel/test-stream-unpipe-event.js | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/test/parallel/test-stream-unpipe-event.js b/test/parallel/test-stream-unpipe-event.js index befa24253d..340502d1a9 100644 --- a/test/parallel/test-stream-unpipe-event.js +++ b/test/parallel/test-stream-unpipe-event.js @@ -1,7 +1,7 @@ 'use strict'; const common = require('../common'); const assert = require('assert'); -const {Writable, Readable} = require('stream'); +const { Writable, Readable } = require('stream'); class NullWriteable extends Writable { _write(chunk, encoding, callback) { return callback(); @@ -55,7 +55,7 @@ class NeverEndReadable extends Readable { const src = new QuickEndReadable(); dest.on('pipe', common.mustCall()); dest.on('unpipe', common.mustCall()); - src.pipe(dest, {end: false}); + src.pipe(dest, { end: false }); setImmediate(() => { assert.strictEqual(src._readableState.pipesCount, 0); }); @@ -66,7 +66,7 @@ class NeverEndReadable extends Readable { const src = new NeverEndReadable(); dest.on('pipe', common.mustCall()); dest.on('unpipe', common.mustNotCall('unpipe should not have been emitted')); - src.pipe(dest, {end: false}); + src.pipe(dest, { end: false }); setImmediate(() => { assert.strictEqual(src._readableState.pipesCount, 1); }); @@ -77,7 +77,7 @@ class NeverEndReadable extends Readable { const src = new NeverEndReadable(); dest.on('pipe', common.mustCall()); dest.on('unpipe', common.mustCall()); - src.pipe(dest, {end: false}); + src.pipe(dest, { end: false }); src.unpipe(dest); setImmediate(() => { assert.strictEqual(src._readableState.pipesCount, 0); |