Function startConnection

www/js/ext/eventsource.esm.js:246–273

(stub)

  return stub;
}
function startConnection(stub) {
  var ac = new AbortController();
  stub.abortController = ac;
  var fetchOptions = {
    method: stub.method,
    signal: ac.signal,
    headers: Object.assign({}, stub.headers || {})
  };
  if (stub.withCredentials) {
    fetchOptions.credentials = "include";
  }
  if (stub.lastEventId) {
    fetchOptions.headers["Last-Event-ID"] = stub.lastEventId;
  }
  fetch(stub.url, fetchOptions).then(function(response) {
    if (ac.signal.aborted) return;
    if (!response.ok) {
      throw new Error("SSE connection failed with status " + response.status);
    }
    stub.retryCount = 0;
    dispatch(stub, "open", { type: "open" });
    return readStream(stub, response.body.getReader(), ac);
  }).catch(function(err) {
    if (ac.signal.aborted) return;
    dispatch(stub, "error", { type: "error", error: err });
    scheduleReconnect(stub);
  });
}
async function readStream(stub, reader, ac) {
  stub.reader = reader;
  var baseDelay = 500;