Function readStream

src/ext/eventsource.js:282–313

(stub, reader, ac)

}

async function readStream(stub, reader, ac) {
	stub.reader = reader;
	var baseDelay = 500;

	try {
		for await (var msg of parseSSE(reader)) {
			if (ac.signal.aborted) break;

			if (msg.id) stub.lastEventId = msg.id;
			if (msg.retry != null) baseDelay = msg.retry;

			var eventType = msg.event || 'message';
			var evt = {
				type: eventType,
				data: msg.data,
				lastEventId: msg.id || stub.lastEventId || '',
			};
			dispatch(stub, eventType, evt);
		}
	} catch (err) {
		if (!ac.signal.aborted) {
			dispatch(stub, 'error', { type: 'error', error: err });
		}
	}

	stub.reader = null;

	// Stream ended - reconnect unless explicitly closed
	if (!stub.closed && !ac.signal.aborted) {
		scheduleReconnect(stub, baseDelay);
	}
}

function scheduleReconnect(stub, baseDelay) {
	if (stub.closed) return;