(data)
| 18052 | failWebsocketConnectionWithCode(this.ws, code, error.message); |
| 18053 | return; |
| 18054 | } |
| 18055 | if (!this.writeFragments(data)) { |
| 18056 | return; |
| 18057 | } |
| 18058 | if (__privateGet(this, _maxPayloadSize) > 0 && __privateGet(this, _fragmentsBytes) > __privateGet(this, _maxPayloadSize)) { |
| 18059 | failWebsocketConnectionWithCode(this.ws, 1009, new MessageSizeExceededError().message); |
| 18060 | return; |
| 18061 | } |
| 18062 | if (!__privateGet(this, _info).fin) { |
| 18063 | __privateSet(this, _state, parserStates.INFO); |
| 18064 | __privateSet(this, _loop, true); |
| 18065 | this.run(callback); |
| 18066 | return; |
| 18067 | } |
| 18068 | websocketMessageReceived(this.ws, __privateGet(this, _info).binaryType, this.consumeFragments()); |
| 18069 | __privateSet(this, _loop, true); |
| 18070 | __privateSet(this, _state, parserStates.INFO); |
| 18071 | this.run(callback); |
| 18072 | } |
| 18073 | ); |
| 18074 | __privateSet(this, _loop, false); |
| 18075 | break; |
| 18076 | } |
no test coverage detected