Method parseControlFrame

github-actions/saucelabs/set-saucelabs-env.js:18078–18129

* Parses control frames. * @param {Buffer} body

(body)

                }
              }
            }
          }
        }
        /**
         * Take n bytes from the buffered Buffers
         * @param {number} n
         * @returns {Buffer}
         */
        consume(n) {
          if (n > __privateGet(this, _byteOffset)) {
            throw new Error("Called consume() before buffers satiated.");
          } else if (n === 0) {
            return emptyBuffer;
          }
          if (__privateGet(this, _buffers)[0].length === n) {
            __privateSet(this, _byteOffset, __privateGet(this, _byteOffset) - __privateGet(this, _buffers)[0].length);
            return __privateGet(this, _buffers).shift();
          }
          const buffer = Buffer.allocUnsafe(n);
          let offset = 0;
          while (offset !== n) {
            const next = __privateGet(this, _buffers)[0];
            const { length } = next;
            if (length + offset === n) {
              buffer.set(__privateGet(this, _buffers).shift(), offset);
              break;
            } else if (length + offset > n) {
              buffer.set(next.subarray(0, n - offset), offset);
              __privateGet(this, _buffers)[0] = next.subarray(n - offset);
              break;
            } else {
              buffer.set(__privateGet(this, _buffers).shift(), offset);
              offset += next.length;
            }
          }
          __privateSet(this, _byteOffset, __privateGet(this, _byteOffset) - n);
          return buffer;
        }
        writeFragments(fragment) {
          if (__privateGet(this, _maxFragments) > 0 && __privateGet(this, _fragments).length === __privateGet(this, _maxFragments)) {
            failWebsocketConnectionWithCode(this.ws, 1008, "Too many message fragments");
            return false;
          }
          __privateSet(this, _fragmentsBytes, __privateGet(this, _fragmentsBytes) + fragment.length);
          __privateGet(this, _fragments).push(fragment);
          return true;
        }
        consumeFragments() {
          const fragments = __privateGet(this, _fragments);
          if (fragments.length === 1) {
            __privateSet(this, _fragmentsBytes, 0);
            return fragments.shift();
          }
          const output = Buffer.concat(fragments, __privateGet(this, _fragmentsBytes));
          __privateSet(this, _fragments, []);