(decoder: decoding.Decoder)
| 483 | } |
| 484 | |
| 485 | private async _handleDocMessage(decoder: decoding.Decoder) { |
| 486 | const messageType = decoding.readVarUint(decoder); |
| 487 | |
| 488 | switch (messageType) { |
| 489 | case CollabClientDocMessageType.ALL_UPDATES_UNMERGED_RESPONSE: |
| 490 | await this._handleDocAllUpdatesUnmergedResponseMessage(decoder); |
| 491 | break; |
| 492 | case CollabClientDocMessageType.SINGLE_UPDATE: |
| 493 | await this._handleDocSingleUpdateMessage(decoder); |
| 494 | break; |
| 495 | default: |
| 496 | throw new Error('Unknown sync message type'); |
| 497 | } |
| 498 | } |
| 499 | |
| 500 | private async _handleDocAllUpdatesUnmergedResponseMessage( |
| 501 | decoder: decoding.Decoder, |
no test coverage detected