Function writeH2

github-actions/browserstack/set-browserstack-env.js:7246–7478

(client, request)

        if (this[kHTTP2Session] != null) {
          this[kHTTP2Session].destroy(err);
          this[kHTTP2Session] = null;
        }
        util.destroy(this[kSocket], err);
        if (client[kRunningIdx] < client[kQueue].length) {
          const request = client[kQueue][client[kRunningIdx]];
          client[kQueue][client[kRunningIdx]++] = null;
          util.errorRequest(client, request, err);
          client[kPendingIdx] = client[kRunningIdx];
        }
        assert(client[kRunning] === 0);
        client.emit("disconnect", client[kUrl], [client], err);
        client[kResume]();
      }
      function shouldSendContentLength(method) {
        return method !== "GET" && method !== "HEAD" && method !== "OPTIONS" && method !== "TRACE" && method !== "CONNECT";
      }
      function writeH2(client, request) {
        const session = client[kHTTP2Session];
        const { method, path: path4, host, upgrade, expectContinue, signal, headers: reqHeaders } = request;
        let { body } = request;
        if (upgrade) {
          util.errorRequest(client, request, new Error("Upgrade not supported for H2"));
          return false;
        }
        const headers = {};
        for (let n = 0; n < reqHeaders.length; n += 2) {
          const key = reqHeaders[n + 0];
          const val = reqHeaders[n + 1];
          if (Array.isArray(val)) {
            for (let i = 0; i < val.length; i++) {
              if (headers[key]) {
                headers[key] += `,${val[i]}`;
              } else {
                headers[key] = val[i];
              }
            }
          } else {
            headers[key] = val;
          }
        }
        let stream;
        const { hostname, port } = client[kUrl];
        headers[HTTP2_HEADER_AUTHORITY] = host || `${hostname}${port ? `:${port}` : ""}`;
        headers[HTTP2_HEADER_METHOD] = method;
        const abort = (err) => {
          if (request.aborted || request.completed) {
            return;
          }
          err = err || new RequestAbortedError();
          util.errorRequest(client, request, err);
          if (stream != null) {
            util.destroy(stream, err);
          }
          util.destroy(body, err);
          client[kQueue][client[kRunningIdx]++] = null;
          client[kResume]();
        };
        try {