Method decode

packages/baseai/src/dev/utils/stream/stream.ts:322–363

(line: string)

	}

	decode(line: string) {
		if (line.endsWith('\r')) {
			line = line.substring(0, line.length - 1);
		}

		if (!line) {
			// empty line and we didn't previously encounter any messages
			if (!this.event && !this.data.length) return null;

			const sse: ServerSentEvent = {
				event: this.event,
				data: this.data.join('\n'),
				raw: this.chunks
			};

			this.event = null;
			this.data = [];
			this.chunks = [];

			return sse;
		}

		this.chunks.push(line);

		if (line.startsWith(':')) {
			return null;
		}

		let [fieldname, _, value] = partition(line, ':');

		if (value.startsWith(' ')) {
			value = value.substring(1);
		}

		if (fieldname === 'event') {
			this.event = value;
		} else if (fieldname === 'data') {
			this.data.push(value);
		}

		return null;
	}
}

/**