Class AsyncIterableIteratorToArrayWrapperImpl

src/scan-iterator.ts:149–169

}

class AsyncIterableIteratorToArrayWrapperImpl<V>
  implements AsyncIterableIterator<V>
{
  private readonly _it: AsyncIterableIterator<V>;

  constructor(it: AsyncIterableIterator<V>) {
    this._it = it;
  }

  next() {
    return this._it.next();
  }

  [Symbol.asyncIterator](): AsyncIterableIterator<V> {
    return this._it[Symbol.asyncIterator]();
  }

  toArray(): Promise<V[]> {
    return asyncIterableToArray(this._it);
  }
}

async function* scanIterator<Options extends ScanOptions, Value>(
  toValue: ToValue<Options, Value>,