Method onMessageComplete

github-actions/browserstack/set-browserstack-env.js:6382–6427

()

          assert(statusCode >= 200);
          if (maxResponseSize > -1 && this.bytesRead + buf.length > maxResponseSize) {
            util.destroy(socket, new ResponseExceededMaxSizeError());
            return -1;
          }
          this.bytesRead += buf.length;
          if (request.onData(buf) === false) {
            return constants3.ERROR.PAUSED;
          }
        }
        onMessageComplete() {
          const { client, socket, statusCode, upgrade, headers, contentLength, bytesRead, shouldKeepAlive } = this;
          if (socket.destroyed && (!statusCode || shouldKeepAlive)) {
            return -1;
          }
          if (upgrade) {
            return;
          }
          assert(statusCode >= 100);
          assert((this.headers.length & 1) === 0);
          const request = client[kQueue][client[kRunningIdx]];
          assert(request);
          this.statusCode = null;
          this.statusText = "";
          this.bytesRead = 0;
          this.contentLength = "";
          this.keepAlive = "";
          this.connection = "";
          this.headers = [];
          this.headersSize = 0;
          if (statusCode < 200) {
            return;
          }
          if (request.method !== "HEAD" && contentLength && bytesRead !== parseInt(contentLength, 10)) {
            util.destroy(socket, new ResponseContentLengthMismatchError());
            return -1;
          }
          request.onComplete(headers);
          client[kQueue][client[kRunningIdx]++] = null;
          socket[kSocketUsed] = true;
          if (socket[kWriting]) {
            assert(client[kRunning] === 0);
            util.destroy(socket, new InformationalError("reset"));
            return constants3.ERROR.PAUSED;
          } else if (!shouldKeepAlive) {
            util.destroy(socket, new InformationalError("reset"));
            return constants3.ERROR.PAUSED;
          } else if (socket[kReset] && client[kRunning] === 0) {
            util.destroy(socket, new InformationalError("reset"));
            return constants3.ERROR.PAUSED;
          } else if (client[kPipelining] == null || client[kPipelining] === 1) {