Function _iterSSEMessages

packages/core/src/common/stream.ts:216–240

(
	response: Response,
	controller: AbortController,
)

 * @throws Error if the response has no body.
 */
export async function* _iterSSEMessages(
	response: Response,
	controller: AbortController,
): AsyncGenerator<ServerSentEvent, void, unknown> {
	if (!response.body) {
		controller.abort();
		throw new Error(`Attempted to iterate over a response with no body`);
	}

	const sseDecoder = new SSEDecoder();
	const lineDecoder = new LineDecoder();

	const iter = readableStreamAsyncIterable<Bytes>(response.body);
	for await (const sseChunk of iterSSEChunks(iter)) {
		for (const line of lineDecoder.decode(sseChunk)) {
			const sse = sseDecoder.decode(line);
			if (sse) yield sse;
		}
	}

	for (const line of lineDecoder.flush()) {
		const sse = sseDecoder.decode(line);
		if (sse) yield sse;
	}
}

/**
 * Asynchronously iterates over SSE (Server-Sent Events) chunks and yields the data as Uint8Array.