Function readStream

www/js/ext/eventsource.esm.js:274–299

(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;
  if (!stub.closed && !ac.signal.aborted) {
    scheduleReconnect(stub, baseDelay);
  }
}
function scheduleReconnect(stub, baseDelay) {
  if (stub.closed) return;
  baseDelay = baseDelay || 500;