diff --git a/test/parallel/test-stream-iter-validation.js b/test/parallel/test-stream-iter-validation.js index 19cde169d6f496..10d1a4dc71536a 100644 --- a/test/parallel/test-stream-iter-validation.js +++ b/test/parallel/test-stream-iter-validation.js @@ -3,8 +3,9 @@ const common = require('../common'); const assert = require('assert'); +const { Writable } = require('stream'); const { - from, fromSync, pull, pullSync, pipeTo, + from, fromSync, fromWritable, pull, pullSync, pipeTo, push, duplex, broadcast, Broadcast, share, shareSync, Share, SyncShare, bytes, bytesSync, text, textSync, @@ -161,6 +162,17 @@ assert.throws(() => broadcast({ backpressure: 'bad' }), { code: 'ERR_INVALID_ARG assert.throws(() => Broadcast.from(42), { code: 'ERR_INVALID_ARG_TYPE' }); assert.throws(() => Broadcast.from('bad'), { code: 'ERR_INVALID_ARG_TYPE' }); +// ============================================================================= +// fromWritable() validation +// ============================================================================= +{ + const writable = new Writable({ write(chunk, encoding, cb) { cb(); } }); + const writer = fromWritable(writable); + assert.throws(() => writer.writev('bad'), { code: 'ERR_INVALID_ARG_TYPE' }); + assert.throws(() => writer.writev(42), { code: 'ERR_INVALID_ARG_TYPE' }); + writer.endSync(); +} + // ============================================================================= // share() / shareSync() validation // =============================================================================