Function yieldAbortable

lib/internal/streams/iter/pull.js:729–766

* Wrap an async source so each pending read is abort-aware. * @param {AsyncIterable } source - The source to read from. * @param {AbortSignal|undefined} signal - Optional abort signal. * @returns {AsyncIterable }

(source, signal)

 * @returns {AsyncIterable<Uint8Array[]>}
 */
function yieldAbortable(source, signal) {
  if (signal === undefined) {
    return source;
  }

  return {
    __proto__: null,
    async *[SymbolAsyncIterator]() {
      const iterator = source[SymbolAsyncIterator]();
      let completed = false;
      let aborted = false;

      try {
        while (true) {
          const { done, value } = await abortableNext(iterator, signal);
          if (done) {
            completed = true;
            return;
          }
          signal.throwIfAborted();
          yield value;
        }
      } catch (error) {
        aborted = signal.aborted;
        throw error;
      } finally {
        if (!completed && typeof iterator.return === 'function') {
          const result = iterator.return();
          if (aborted) {
            markPromiseAsHandled(result);
          } else {
            await result;
          }
        }
      }
    },
  };
}

/**
 * Create an async pipeline from source through transforms.