Function writeIterable

github-actions/browserstack/set-browserstack-env.js:6883–6932

(abort, body, client, request, socket, contentLength, header, expectsPayload)

            const buffer = Buffer.from(yield body.arrayBuffer());
            socket.cork();
            socket.write(`${header}content-length: ${contentLength}\r
\r
`, "latin1");
            socket.write(buffer);
            socket.uncork();
            request.onBodySent(buffer);
            request.onRequestSent();
            if (!expectsPayload && request.reset !== false) {
              socket[kReset] = true;
            }
            client[kResume]();
          } catch (err) {
            abort(err);
          }
        });
      }
      function writeIterable(abort, body, client, request, socket, contentLength, header, expectsPayload) {
        return __async(this, null, function* () {
          assert(contentLength !== 0 || client[kRunning] === 0, "iterator body cannot be pipelined");
          let callback = null;
          function onDrain() {
            if (callback) {
              const cb = callback;
              callback = null;
              cb();
            }
          }
          const waitForDrain = () => new Promise((resolve2, reject) => {
            assert(callback === null);
            if (socket[kError]) {
              reject(socket[kError]);
            } else {
              callback = resolve2;
            }
          });
          socket.on("close", onDrain).on("drain", onDrain);
          const writer = new AsyncWriter({ abort, socket, request, contentLength, client, expectsPayload, header });
          try {
            try {
              for (var iter = __forAwait(body), more, temp, error; more = !(temp = yield iter.next()).done; more = false) {
                const chunk = temp.value;
                if (socket[kError]) {
                  throw socket[kError];
                }
                if (!writer.write(chunk)) {
                  yield waitForDrain();
                }
              }
            } catch (temp) {
              error = [temp];
            } finally {
              try {
                more && (temp = iter.return) && (yield temp.call(iter));