Lines Matching refs:signal
24 } = require('internal/streams/add-abort-signal');
48 if (options?.signal != null) {
49 validateAbortSignal(options.signal, 'options.signal');
58 if (options?.signal) {
61 options.signal,
77 if (options?.signal != null) {
78 validateAbortSignal(options.signal, 'options.signal');
97 const signal = AbortSignal.any([options?.signal].filter(Boolean));
100 const signalOpt = { signal };
136 if (signal.aborted) {
193 if (signal.aborted) {
223 if (options?.signal != null) {
224 validateAbortSignal(options.signal, 'options.signal');
230 if (options?.signal?.aborted) {
231 throw new AbortError({ cause: options.signal.reason });
307 if (options?.signal != null) {
308 validateAbortSignal(options.signal, 'options.signal');
312 if (options?.signal?.aborted) {
313 const err = new AbortError(undefined, { cause: options.signal.reason });
319 const signal = ac.signal;
320 if (options?.signal) {
322 options.signal.addEventListener('abort', () => ac.abort(), opts);
328 if (options?.signal?.aborted) {
335 initialValue = await reducer(initialValue, value, { signal });
351 if (options?.signal != null) {
352 validateAbortSignal(options.signal, 'options.signal');
357 if (options?.signal?.aborted) {
358 throw new AbortError(undefined, { cause: options.signal.reason });
391 if (options?.signal != null) {
392 validateAbortSignal(options.signal, 'options.signal');
397 if (options?.signal?.aborted) {
401 if (options?.signal?.aborted) {
415 if (options?.signal != null) {
416 validateAbortSignal(options.signal, 'options.signal');
421 if (options?.signal?.aborted) {
425 if (options?.signal?.aborted) {