Function onHeaders

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

(status, rawHeaders, resume, statusText)

              }
              timingInfo.decodedBodySize += (_a2 = bytes == null ? void 0 : bytes.byteLength) != null ? _a2 : 0;
              if (isFailure) {
                fetchParams.controller.terminate(bytes);
                return;
              }
              const buffer = new Uint8Array(bytes);
              if (buffer.byteLength) {
                fetchParams.controller.controller.enqueue(buffer);
              }
              if (isErrored(stream)) {
                fetchParams.controller.terminate();
                return;
              }
              if (fetchParams.controller.controller.desiredSize <= 0) {
                return;
              }
            }
          });
          function onAborted(reason) {
            if (isAborted(fetchParams)) {
              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);