Method decode

packages/baseai/src/dev/utils/stream/stream.ts:386–428

(chunk: Bytes)

	}

	decode(chunk: Bytes): string[] {
		let text = this.decodeText(chunk);

		if (this.trailingCR) {
			text = '\r' + text;
			this.trailingCR = false;
		}
		if (text.endsWith('\r')) {
			this.trailingCR = true;
			text = text.slice(0, -1);
		}

		if (!text) {
			return [];
		}

		const trailingNewline = LineDecoder.NEWLINE_CHARS.has(
			text[text.length - 1] || ''
		);
		let lines = text.split(LineDecoder.NEWLINE_REGEXP);

		// if there is a trailing new line then the last entry will be an empty
		// string which we don't care about
		if (trailingNewline) {
			lines.pop();
		}

		if (lines.length === 1 && !trailingNewline) {
			this.buffer.push(lines[0]!);
			return [];
		}

		if (this.buffer.length > 0) {
			lines = [this.buffer.join('') + lines[0], ...lines.slice(1)];
			this.buffer = [];
		}

		if (!trailingNewline) {
			this.buffer = [lines.pop() || ''];
		}

		return lines;
	}

	decodeText(bytes: Bytes): string {
		if (bytes == null) return '';