Function connectH2

github-actions/saucelabs/set-saucelabs-env.js:7109–7193

(client, socket)

          HTTP2_HEADER_CONTENT_LENGTH,
          HTTP2_HEADER_EXPECT,
          HTTP2_HEADER_STATUS
        }
      } = http2;
      function parseH2Headers(headers) {
        const result = [];
        for (const [name, value] of Object.entries(headers)) {
          if (Array.isArray(value)) {
            for (const subvalue of value) {
              result.push(Buffer.from(name), Buffer.from(subvalue));
            }
          } else {
            result.push(Buffer.from(name), Buffer.from(value));
          }
        }
        return result;
      }
      function connectH2(client, socket) {
        return __async(this, null, function* () {
          client[kSocket] = socket;
          if (!h2ExperimentalWarned) {
            h2ExperimentalWarned = true;
            process.emitWarning("H2 support is experimental, expect them to change at any time.", {
              code: "UNDICI-H2"
            });
          }
          const session = http2.connect(client[kUrl], {
            createConnection: () => socket,
            peerMaxConcurrentStreams: client[kMaxConcurrentStreams]
          });
          session[kOpenStreams] = 0;
          session[kClient] = client;
          session[kSocket] = socket;
          util.addListener(session, "error", onHttp2SessionError);
          util.addListener(session, "frameError", onHttp2FrameError);
          util.addListener(session, "end", onHttp2SessionEnd);
          util.addListener(session, "goaway", onHTTP2GoAway);
          util.addListener(session, "close", function() {
            const { [kClient]: client2 } = this;
            const { [kSocket]: socket2 } = client2;
            const err = this[kSocket][kError] || this[kError] || new SocketError("closed", util.getSocketInfo(socket2));
            client2[kHTTP2Session] = null;
            if (client2.destroyed) {
              assert(client2[kPending] === 0);
              const requests = client2[kQueue].splice(client2[kRunningIdx]);
              for (let i = 0; i < requests.length; i++) {
                const request = requests[i];
                util.errorRequest(client2, request, err);
              }
            }
          });
          session.unref();
          client[kHTTP2Session] = session;
          socket[kHTTP2Session] = session;
          util.addListener(socket, "error", function(err) {
            assert(err.code !== "ERR_TLS_CERT_ALTNAME_INVALID");
            this[kError] = err;
            this[kClient][kOnError](err);
          });