f2108fa51dBackport-PR-URL: https://github.com/nodejs/node/pull/17068 PR-URL: https://github.com/nodejs/node/pull/16938 Reviewed-By: Refael Ackermann <refack@gmail.com> Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Colin Ihrig <cjihrig@gmail.com> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Gireesh Punathil <gpunathi@in.ibm.com>
55 lines
1.3 KiB
JavaScript
55 lines
1.3 KiB
JavaScript
'use strict';
|
|
require('../common');
|
|
const assert = require('assert');
|
|
|
|
const stream = require('stream');
|
|
|
|
class MyWritable extends stream.Writable {
|
|
constructor(opt) {
|
|
super(opt);
|
|
}
|
|
|
|
_write(chunk, encoding, callback) {
|
|
assert.notStrictEqual(chunk, null);
|
|
callback();
|
|
}
|
|
}
|
|
|
|
assert.throws(() => {
|
|
const m = new MyWritable({objectMode: true});
|
|
m.write(null, (err) => assert.ok(err));
|
|
}, /^TypeError: May not write null values to stream$/);
|
|
assert.doesNotThrow(() => {
|
|
const m = new MyWritable({objectMode: true}).on('error', (e) => {
|
|
assert.ok(e);
|
|
});
|
|
m.write(null, (err) => {
|
|
assert.ok(err);
|
|
});
|
|
});
|
|
|
|
assert.throws(() => {
|
|
const m = new MyWritable();
|
|
m.write(false, (err) => assert.ok(err));
|
|
}, /^TypeError: Invalid non-string\/buffer chunk$/);
|
|
assert.doesNotThrow(() => {
|
|
const m = new MyWritable().on('error', (e) => {
|
|
assert.ok(e);
|
|
});
|
|
m.write(false, (err) => {
|
|
assert.ok(err);
|
|
});
|
|
});
|
|
|
|
assert.doesNotThrow(() => {
|
|
const m = new MyWritable({objectMode: true});
|
|
m.write(false, (err) => assert.ifError(err));
|
|
});
|
|
assert.doesNotThrow(() => {
|
|
const m = new MyWritable({objectMode: true}).on('error', (e) => {
|
|
assert.ifError(e || new Error('should not get here'));
|
|
});
|
|
m.write(false, (err) => {
|
|
assert.ifError(err);
|
|
});
|
|
});
|