Method teeIterator

packages/baseai/src/dev/utils/stream/stream.ts:162–175

(
			queue: Array<Promise<IteratorResult<Item>>>
		)

		const iterator = this.iterator();

		const teeIterator = (
			queue: Array<Promise<IteratorResult<Item>>>
		): AsyncIterator<Item> => {
			return {
				next: () => {
					if (queue.length === 0) {
						const result = iterator.next();
						left.push(result);
						right.push(result);
					}
					return queue.shift()!;
				}
			};
		};

		return [
			new Stream(() => teeIterator(left), this.controller),