( decoder: decoding.Decoder, encoder: encoding.Encoder, doc: Y.Doc, transactionOrigin: any, )
| 183 | }) |
| 184 | |
| 185 | const readSyncMetaMessage = ( |
| 186 | decoder: decoding.Decoder, |
| 187 | encoder: encoding.Encoder, |
| 188 | doc: Y.Doc, |
| 189 | transactionOrigin: any, |
| 190 | ) => { |
| 191 | const meta = decoding.readAny(decoder) |
| 192 | if (!transactionOrigin) { |
| 193 | transactionOrigin = meta |
| 194 | } |
| 195 | return syncProtocol.readSyncMessage(decoder, encoder, doc, transactionOrigin, () => { |
| 196 | encoding.writeAny(encoder, meta) |
| 197 | }) |
| 198 | } |
| 199 | |
| 200 | const messageListener = ( |
| 201 | conn: WebSocket.WebSocket, |
no outgoing calls
no test coverage detected
searching dependent graphs…