Method next

src/utils/stream.ts:19–37

()

  }

  next(): Promise<IteratorResult<T, unknown>> {
    if (this.queue.length > 0) {
      return Promise.resolve({
        done: false,
        value: this.queue.shift()!,
      })
    }
    // Error checks before done so a late stream.error() never gets swallowed
    if (this.hasError) {
      return Promise.reject(this.hasError)
    }
    if (this.isDone) {
      return Promise.resolve({ done: true, value: undefined })
    }
    return new Promise<IteratorResult<T>>((resolve, reject) => {
      this.readResolve = resolve
      this.readReject = reject
    })
  }

  enqueue(value: T): void {
    if (this.readResolve) {