* @param {Buffer} chunk * @param {() => void} callback
(chunk, _, callback)
| 17833 | callback(err); |
| 17834 | return; |
| 17835 | } |
| 17836 | __privateGet(this, _inflate)[kBuffer] = []; |
| 17837 | __privateGet(this, _inflate)[kLength] = 0; |
| 17838 | __privateGet(this, _inflate).on("data", (data) => { |
| 17839 | __privateGet(this, _inflate)[kLength] += data.length; |
| 17840 | if (__privateGet(this, _maxPayloadSize) > 0 && __privateGet(this, _inflate)[kLength] > __privateGet(this, _maxPayloadSize)) { |
| 17841 | callback(new MessageSizeExceededError()); |
| 17842 | __privateGet(this, _inflate).removeAllListeners(); |
| 17843 | __privateGet(this, _inflate).destroy(); |
nothing calls this directly
no test coverage detected