123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
export type Awaitable<T> = T | Promise<T>;export type ForOfAwaitable<T> = Iterable<T> | AsyncIterable<T>;
export const isIterable = <T>(x: unknown): x is Iterable<T> =>   x != null && typeof x === 'object' && Symbol.iterator in x
export const isAsyncIterable = <T>(x: unknown): x is AsyncIterable<T> =>   x != null && typeof x === 'object' && Symbol.asyncIterator in x
export const isForOfAwaitable = <T>(x: unknown): x is ForOfAwaitable<T> =>   x != null && typeof x === 'object' && (Symbol.asyncIterator in x || Symbol.iterator in x)
/** * Alternates items from the first and second iterable in the output iterable, until either input runs out of items. */export function* interleave<X, Y>(xs: Iterable<X>, ys: Iterable<Y>): IterableIterator<X | Y> {  const itx = xs[Symbol.iterator]();  const ity = ys[Symbol.iterator]();  while (true) {    const rx = itx.next();    if (rx.done) break;    else yield rx.value;    const ry = ity.next();    if (ry.done) break;    else yield ry.value;  }}
/** * It's like interleave, but will flatten items of the second (async) iterable. */export async function* aInterleaveFlattenSecond<X, Y>(xs: Iterable<X>, ys: Iterable<AsyncIterable<Y>>): AsyncIterableIterator<X | Y> {  const itx = xs[Symbol.iterator]();  const ity = ys[Symbol.iterator]();  while (true) {    const rx = itx.next();    if (rx.done) break;    else yield rx.value;    const ry = ity.next();    if (ry.done) break;    else yield* ry.value;  }}
export function* map<A, B>(iterable: Iterable<A>, f: (a: A) => B): IterableIterator<B> {  for (const x of iterable) yield f(x);}
export async function* aMap<A, B>(iterable: ForOfAwaitable<A>, f: (a: A) => Awaitable<B>): AsyncIterableIterator<B> {  for await (const x of iterable) yield f(x);}
export function join(iterable: Iterable<string>): string {  return [...iterable].join('');}
export async function aJoin(iterable: ForOfAwaitable<string>): Promise<string> {  const chunks = [];  for await (const x of iterable) chunks.push(x);  return chunks.join('');}
export async function aConsume<T>(iterable: ForOfAwaitable<T>): Promise<T[]> {  const chunks = [];  for await (const x of iterable) chunks.push(x);  return chunks}
export async function* promiseToAsyncIterable<T>(promise: Promise<T>): AsyncIterableIterator<T> {  yield await promise;}