({ transaction })
| 287 | }) |
| 288 | |
| 289 | const mutationFn: MutationFn = async ({ transaction }) => { |
| 290 | emitter.emit(`sync`, transaction.mutations) |
| 291 | return Promise.resolve() |
| 292 | } |
| 293 | |
| 294 | // Subscribe to changes |
| 295 | const subscription = collection.subscribeChanges(callback) |
nothing calls this directly
no test coverage detected