Method run

github-actions/saucelabs/set-saucelabs-env.js:17846–17998

* Runs whenever a new chunk is received. * Callback is called whenever there are no more chunks buffering, * or not enough bytes are buffered to parse.

(callback)

          });
        }
      };
      _inflate = new WeakMap();
      _options = new WeakMap();
      _maxPayloadSize = new WeakMap();
      module.exports = { PerMessageDeflate };
    }
  });

  // 
  var require_receiver = __commonJS({
    ""(exports, module) {
      "use strict";
      var { Writable } = __require("stream");
      var assert = __require("assert");
      var { parserStates, opcodes, states, emptyBuffer, sentCloseFrameState } = require_constants5();
      var { kReadyState, kSentClose, kResponse, kReceivedClose } = require_symbols5();
      var { channels } = require_diagnostics();
      var {
        isValidStatusCode,
        isValidOpcode,
        failWebsocketConnection,
        websocketMessageReceived,
        utf8Decode,
        isControlFrame,
        isTextBinaryFrame,
        isContinuationFrame
      } = require_util7();
      var { WebsocketFrameSend } = require_frame();
      var { closeWebSocketConnection } = require_connection();
      var { PerMessageDeflate } = require_permessage_deflate();
      var { MessageSizeExceededError } = require_errors();
      function failWebsocketConnectionWithCode(ws, code, reason) {
        closeWebSocketConnection(ws, code, reason, Buffer.byteLength(reason));
        failWebsocketConnection(ws, reason);
      }
      var _buffers, _fragmentsBytes, _byteOffset, _loop, _state, _info, _fragments, _extensions, _maxFragments, _maxPayloadSize, _validatePayloadLength, validatePayloadLength_fn;
      var ByteParser = class extends Writable {
        /**
         * @param {import('./websocket').WebSocket} ws
         * @param {Map<string, string>|null} extensions
         * @param {{ maxFragments?: number, maxPayloadSize?: number }} [options]
         */
        constructor(ws, extensions, options = {}) {
          var _a, _b;
          super();
          __privateAdd(this, _validatePayloadLength);
          __privateAdd(this, _buffers, []);
          __privateAdd(this, _fragmentsBytes, 0);
          __privateAdd(this, _byteOffset, 0);
          __privateAdd(this, _loop, false);
          __privateAdd(this, _state, parserStates.INFO);
          __privateAdd(this, _info, {});
          __privateAdd(this, _fragments, []);
          /** @type {Map<string, PerMessageDeflate>} */
          __privateAdd(this, _extensions, void 0);
          /** @type {number} */
          __privateAdd(this, _maxFragments, void 0);
          /** @type {number} */