deno.land / std@0.166.0 / node / _tools / test / parallel / test-stream-writable-end-cb-error.js
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586// deno-fmt-ignore-file// deno-lint-ignore-file
// Copyright Joyent and Node contributors. All rights reserved. MIT license.// Taken from Node 18.12.0// This file is automatically generated by "node/_tools/setup.ts". Do not modify this file manually
'use strict';
const common = require('../common');const assert = require('assert');const stream = require('stream');
{ // Invoke end callback on failure. const writable = new stream.Writable();
const _err = new Error('kaboom'); writable._write = (chunk, encoding, cb) => { process.nextTick(cb, _err); };
writable.on('error', common.mustCall((err) => { assert.strictEqual(err, _err); })); writable.write('asd'); writable.end(common.mustCall((err) => { assert.strictEqual(err, _err); })); writable.end(common.mustCall((err) => { assert.strictEqual(err, _err); }));}
{ // Don't invoke end callback twice const writable = new stream.Writable();
writable._write = (chunk, encoding, cb) => { process.nextTick(cb); };
let called = false; writable.end('asd', common.mustCall((err) => { called = true; assert.strictEqual(err, undefined); }));
writable.on('error', common.mustCall((err) => { assert.strictEqual(err.message, 'kaboom'); })); writable.on('finish', common.mustCall(() => { assert.strictEqual(called, true); writable.emit('error', new Error('kaboom')); }));}
{ const w = new stream.Writable({ write(chunk, encoding, callback) { setImmediate(callback); }, finish(callback) { setImmediate(callback); } }); w.end('testing ended state', common.mustCall((err) => { assert.strictEqual(err.code, 'ERR_STREAM_WRITE_AFTER_END'); })); assert.strictEqual(w.destroyed, false); assert.strictEqual(w.writableEnded, true); w.end(common.mustCall((err) => { assert.strictEqual(err.code, 'ERR_STREAM_WRITE_AFTER_END'); })); assert.strictEqual(w.destroyed, false); assert.strictEqual(w.writableEnded, true); w.end('end', common.mustCall((err) => { assert.strictEqual(err.code, 'ERR_STREAM_WRITE_AFTER_END'); })); assert.strictEqual(w.destroyed, true); w.on('error', common.mustCall((err) => { assert.strictEqual(err.code, 'ERR_STREAM_WRITE_AFTER_END'); })); w.on('finish', common.mustNotCall());}
Version Info