1// Flags: --expose-internals 2'use strict'; 3 4require('../common'); 5const assert = require('assert'); 6const { addAbortSignal, Readable } = require('stream'); 7const { 8 addAbortSignalNoValidate, 9} = require('internal/streams/add-abort-signal'); 10 11{ 12 assert.throws(() => { 13 addAbortSignal('INVALID_SIGNAL'); 14 }, /ERR_INVALID_ARG_TYPE/); 15 16 const ac = new AbortController(); 17 assert.throws(() => { 18 addAbortSignal(ac.signal, 'INVALID_STREAM'); 19 }, /ERR_INVALID_ARG_TYPE/); 20} 21 22{ 23 const r = new Readable({ 24 read: () => {}, 25 }); 26 assert.deepStrictEqual(r, addAbortSignalNoValidate('INVALID_SIGNAL', r)); 27} 28