()
| 18041 | if (!__privateGet(this, _info).fragmented && __privateGet(this, _info).fin) { |
| 18042 | websocketMessageReceived(this.ws, __privateGet(this, _info).binaryType, this.consumeFragments()); |
| 18043 | } |
| 18044 | __privateSet(this, _state, parserStates.INFO); |
| 18045 | } else { |
| 18046 | __privateGet(this, _extensions).get("permessage-deflate").decompress( |
| 18047 | body, |
| 18048 | __privateGet(this, _info).fin, |
| 18049 | (error, data) => { |
| 18050 | if (error) { |
| 18051 | const code = error instanceof MessageSizeExceededError ? 1009 : 1007; |
| 18052 | failWebsocketConnectionWithCode(this.ws, code, error.message); |
| 18053 | return; |
| 18054 | } |
| 18055 | if (!this.writeFragments(data)) { |
| 18056 | return; |
no test coverage detected