Method decompress

github-actions/browserstack/set-browserstack-env.js:17717–17763

* Decompress a compressed payload. * @param {Buffer} chunk Compressed data * @param {boolean} fin Final fragment flag * @param {Function} callback Callback function

(chunk, fin, callback)

          ws[kReadyState] = states.CLOSING;
        }
      }
      function onSocketData(chunk) {
        if (!this.ws[kByteParser].write(chunk)) {
          this.pause();
        }
      }
      function onSocketClose() {
        var _a;
        const { ws } = this;
        const { [kResponse]: response } = ws;
        response.socket.off("data", onSocketData);
        response.socket.off("close", onSocketClose);
        response.socket.off("error", onSocketError);
        const wasClean = ws[kSentClose] === sentCloseFrameState.SENT && ws[kReceivedClose];
        let code = 1005;
        let reason = "";
        const result = ws[kByteParser].closingInfo;
        if (result && !result.error) {
          code = (_a = result.code) != null ? _a : 1005;
          reason = result.reason;
        } else if (!ws[kReceivedClose]) {
          code = 1006;
        }
        ws[kReadyState] = states.CLOSED;
        fireEvent("close", ws, (type, init) => new CloseEvent(type, init), {
          wasClean,
          code,
          reason
        });
        if (channels.close.hasSubscribers) {
          channels.close.publish({
            websocket: ws,
            code,
            reason
          });
        }
      }
      function onSocketError(error) {
        const { ws } = this;
        ws[kReadyState] = states.CLOSING;
        if (channels.socketError.hasSubscribers) {
          channels.socketError.publish(error);
        }
        this.destroy();
      }
      module.exports = {
        establishWebSocketConnection,
        closeWebSocketConnection
      };
    }