Method run

github-actions/bazel/configure-remote/configure-remote.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)

                __privateSet(this, _inflate, null);
                return;
              }
              __privateGet(this, _inflate)[kBuffer].push(data);
            });
            __privateGet(this, _inflate).on("error", (err) => {
              __privateSet(this, _inflate, null);
              callback(err);
            });
          }
          __privateGet(this, _inflate).write(chunk);
          if (fin) {
            __privateGet(this, _inflate).write(tail);
          }
          __privateGet(this, _inflate).flush(() => {
            if (!__privateGet(this, _inflate)) {
              return;
            }
            const full = Buffer.concat(__privateGet(this, _inflate)[kBuffer], __privateGet(this, _inflate)[kLength]);
            __privateGet(this, _inflate)[kBuffer].length = 0;
            __privateGet(this, _inflate)[kLength] = 0;
            callback(null, full);
          });
        }
      };
      _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;