* Add an async iterable to the stream. * * @param iterable The async iterable to add. * * @example Usage * ```ts * import { MuxAsyncIterator } from "@std/async/mux-async-iterator"; * import { assertEquals } from "@std/assert"; * * async function* gen123(): AsyncIterableIte
(iterable: AsyncIterable<T>)
| 72 | * ``` |
| 73 | */ |
| 74 | add(iterable: AsyncIterable<T>) { |
| 75 | ++this.#iteratorCount; |
| 76 | this.#callIteratorNext(iterable[Symbol.asyncIterator]()); |
| 77 | } |
| 78 | |
| 79 | async #callIteratorNext( |
| 80 | iterator: AsyncIterator<T>, |
no test coverage detected