Method iterate

async/mux_async_iterator.ts:118–138

* Returns an async iterator of the stream. * @returns the async iterator for all the added async iterables. * * @example Usage * ```ts * import { MuxAsyncIterator } from "@std/async/mux-async-iterator"; * import { assertEquals } from "@std/assert"; * * async function* gen123(

()

   * ```
   */
  async *iterate(): AsyncIterableIterator<T> {
    while (this.#iteratorCount > 0) {
      // Sleep until any of the wrapped iterators yields.
      await this.#signal.promise;

      // Note that while we're looping over `yields`, new items may be added.
      for (const { iterator, value } of this.#yields) {
        yield value;
        this.#callIteratorNext(iterator);
      }

      if (this.#throws.length) {
        for (const e of this.#throws) {
          throw e;
        }
      }
      // Clear the `yields` list and reset the `signal` promise.
      this.#yields.length = 0;
      this.#signal = Promise.withResolvers<void>();
    }
  }

  /**
   * Implements an async iterator for the stream.