Function onHeaders

github-actions/browserstack/set-browserstack-env.js:14783–14843

(status, rawHeaders, resume, statusText)

              response.aborted = true;
              if (isReadable(stream)) {
                fetchParams.controller.controller.error(
                  fetchParams.controller.serializedAbortReason
                );
              }
            } else {
              if (isReadable(stream)) {
                fetchParams.controller.controller.error(new TypeError("terminated", {
                  cause: isErrorLike(reason) ? reason : void 0
                }));
              }
            }
            fetchParams.controller.connection.destroy();
          }
          return response;
          function dispatch({ body }) {
            const url = requestCurrentURL(request);
            const agent = fetchParams.controller.dispatcher;
            return new Promise((resolve2, reject) => agent.dispatch(
              {
                path: url.pathname + url.search,
                origin: url.origin,
                method: request.method,
                body: agent.isMockActive ? request.body && (request.body.source || request.body.stream) : body,
                headers: request.headersList.entries,
                maxRedirections: 0,
                upgrade: request.mode === "websocket" ? "websocket" : void 0
              },
              {
                body: null,
                abort: null,
                onConnect(abort) {
                  const { connection } = fetchParams.controller;
                  timingInfo.finalConnectionTimingInfo = clampAndCoarsenConnectionTimingInfo(void 0, timingInfo.postRedirectStartTime, fetchParams.crossOriginIsolatedCapability);
                  if (connection.destroyed) {
                    abort(new DOMException("The operation was aborted.", "AbortError"));
                  } else {
                    fetchParams.controller.on("terminated", abort);
                    this.abort = connection.abort = abort;
                  }
                  timingInfo.finalNetworkRequestStartTime = coarsenedSharedCurrentTime(fetchParams.crossOriginIsolatedCapability);
                },
                onResponseStarted() {
                  timingInfo.finalNetworkResponseStartTime = coarsenedSharedCurrentTime(fetchParams.crossOriginIsolatedCapability);
                },
                onHeaders(status, rawHeaders, resume, statusText) {
                  if (status < 200) {
                    return;
                  }
                  let location = "";
                  const headersList = new HeadersList();
                  for (let i = 0; i < rawHeaders.length; i += 2) {
                    headersList.append(bufferToLowerCasedHeaderName(rawHeaders[i]), rawHeaders[i + 1].toString("latin1"), true);
                  }
                  location = headersList.get("location", true);
                  this.body = new Readable({ read: resume });
                  const decoders = [];
                  const willFollow = location && request.redirect === "follow" && redirectStatusSet.has(status);
                  if (request.method !== "HEAD" && request.method !== "CONNECT" && !nullBodyStatus.includes(status) && !willFollow) {