Function mapAsyncIterable

src/execution/mapAsyncIterable.ts:12–33

(
  iterable: AsyncGenerator<T> | AsyncIterable<T>,
  callback: (value: T) => PromiseOrValue<U>,
)

 * @internal
 */
export function mapAsyncIterable<T, U>(
  iterable: AsyncGenerator<T> | AsyncIterable<T>,
  callback: (value: T) => PromiseOrValue<U>,
): AsyncGenerator<U, void, void> {
  const iterator = iterable[Symbol.asyncIterator]();
  const returnFn = iterator.return?.bind(iterator);
  const throwFn = iterator.throw?.bind(iterator);

  const onReturn = returnFn
    ? () => callIgnoringErrors(returnFn)
    : () => Promise.resolve();

  const onThrow = throwFn
    ? (reason?: unknown) => callIgnoringErrors(() => throwFn(reason))
    : onReturn;

  return withConcurrentAbruptClose(
    mapAsyncIterableImpl(iterable, callback),
    onReturn,
    onThrow,
  );
}

async function callIgnoringErrors(fn: () => Promise<unknown>): Promise<void> {
  try {