Lines Matching refs:signal
23 // It also does not allow for signal to not exist on the stream
25 const validateAbortSignal = (signal, name) => {
26 if (typeof signal !== 'object' ||
27 !('aborted' in signal)) {
28 throw new ERR_INVALID_ARG_TYPE(name, 'AbortSignal', signal);
32 module.exports.addAbortSignal = function addAbortSignal(signal, stream) {
33 validateAbortSignal(signal, 'signal');
37 return module.exports.addAbortSignalNoValidate(signal, stream);
40 module.exports.addAbortSignalNoValidate = function(signal, stream) {
41 if (typeof signal !== 'object' || !('aborted' in signal)) {
46 stream.destroy(new AbortError(undefined, { cause: signal.reason }));
49 stream[kControllerErrorFunction](new AbortError(undefined, { cause: signal.reason }));
51 if (signal.aborted) {
55 const disposable = addAbortListener(signal, onAbort);