Function handleAsyncIterator

packages/angular_devkit/architect/src/api.ts:280–298

(
  subscriber: Subscriber<T>,
  iterator: AsyncIterator<T>,
)

}

async function handleAsyncIterator<T>(
  subscriber: Subscriber<T>,
  iterator: AsyncIterator<T>,
): Promise<void> {
  const teardown = new Promise<void>((resolve) => subscriber.add(() => resolve()));

  try {
    while (!subscriber.closed) {
      const result = await Promise.race([teardown, iterator.next()]);
      if (!result || result.done) {
        break;
      }

      subscriber.next(result.value);
    }
  } finally {
    await iterator.return?.();
  }
}

/**
 * A builder handler function. The function signature passed to `createBuilder()`.