( message: Message<T>, )
| 307 | } |
| 308 | |
| 309 | function isSnapshotEndMessage<T extends Row<unknown>>( |
| 310 | message: Message<T>, |
| 311 | ): message is SnapshotEndMessage { |
| 312 | return isControlMessage(message) && message.headers.control === `snapshot-end` |
| 313 | } |
| 314 | |
| 315 | function isSubsetEndMessage<T extends Row<unknown>>( |
| 316 | message: Message<T>, |
no outgoing calls
no test coverage detected