diff --git a/test/parallel/test-stream-writable-ended-state.js b/test/parallel/test-stream-writable-ended-state.js new file mode 100644 index 0000000000..69ba3c88ed --- /dev/null +++ b/test/parallel/test-stream-writable-ended-state.js @@ -0,0 +1,21 @@ +'use strict'; + +const common = require('../common'); + +const assert = require('assert'); +const stream = require('stream'); + +const writable = new stream.Writable(); + +writable._write = (chunk, encoding, cb) => { + assert.strictEqual(writable._writableState.ended, false); + cb(); +}; + +assert.strictEqual(writable._writableState.ended, false); + +writable.end('testing ended state', common.mustCall(() => { + assert.strictEqual(writable._writableState.ended, true); +})); + +assert.strictEqual(writable._writableState.ended, true);