Method tee

packages/baseai/src/dev/utils/stream/stream.ts:157–181

* Splits the stream into two streams which can be * independently read from at different speeds.

()

	 * independently read from at different speeds.
	 */
	tee(): [Stream<Item>, Stream<Item>] {
		const left: Array<Promise<IteratorResult<Item>>> = [];
		const right: 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),
			new Stream(() => teeIterator(right), this.controller)
		];
	}

	/**
	 * Converts this stream to a newline-separated ReadableStream of