Function startConnection

www/js/ext/eventsource.js:247–274

(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;