Method constructor

packages/shared/src/iterator.ts:31–58

(next: AsyncIteratorClassNextFn<T, TReturn>, cleanup: AsyncIteratorClassCleanupFn)

  #next: AsyncIteratorClassNextFn<T, TReturn>

  constructor(next: AsyncIteratorClassNextFn<T, TReturn>, cleanup: AsyncIteratorClassCleanupFn) {
    this.#cleanup = cleanup
    this.#next = sequential(async () => {
      if (this.#isDone) {
        return { done: true, value: undefined as any }
      }

      try {
        const result = await next()

        if (result.done) {
          this.#isDone = true
        }

        return result
      }
      catch (err) {
        this.#isDone = true
        throw err
      }
      finally {
        if (this.#isDone && !this.#isExecuteComplete) {
          this.#isExecuteComplete = true
          await this.#cleanup('next')
        }
      }
    })
  }

  next(): Promise<IteratorResult<T, TReturn>> {
    return this.#next()