Function fromAsyncIterable

packages/angular_devkit/architect/src/api.ts:271–278

(iterable: AsyncIterable<T>)

}

export function fromAsyncIterable<T>(iterable: AsyncIterable<T>): Observable<T> {
  return new Observable((subscriber) => {
    handleAsyncIterator(subscriber, iterable[Symbol.asyncIterator]()).then(
      () => subscriber.complete(),
      (error) => subscriber.error(error),
    );
  });
}

async function handleAsyncIterator<T>(
  subscriber: Subscriber<T>,