!isWebStream(stream)) { throw new ERR_INVALID_ARG_TYPE('stream', ['ReadableStream', 'WritableStream', 'Stream'], stream); } return module.exports.addAbortSignalNoValidate(signal, stream); }; module.exports.addAbortSignalNoValidate = function(signal, stream) { if (typeof signal !== 'object' || !('aborted' in signal)) { return stream; } const onAbort = isNodeStream(stream) ? () => { stream.destroy(new AbortError(undefined, { cause: signal.reason })); } : () => { stream[kControllerErrorFunction](new AbortError(undefined, { cause: signal.reason })); }; if (signal.aborted) { onAbort(); } else { addAbortListener ??= require('events').addAbortListener; const disposable = addAbortListener(signal, onAbort); eos(stream, disposable[SymbolDispose]); } return stream; };