Function onAbort

lib/internal/streams/iter/transform.js:408–416

()

      // Abort handler: reject any in-flight threadpool operation so the
      // generator doesn't block waiting for compression to finish.
      const onAbort = () => {
        const reject = rejectWrite;
        resolveWrite = undefined;
        rejectWrite = undefined;
        if (reject) {
          reject(signal.reason ??
                 lazyDOMException('The operation was aborted', 'AbortError'));
        }
      };
      signal.addEventListener('abort', onAbort, { __proto__: null, once: true });

      // Dispatch input to the threadpool and return a promise.