Function flushDiffRecords

packages/powersync-db-collection/src/powersync.ts:369–380

()

      }

      async function flushDiffRecords(): Promise<void> {
        await database
          .writeTransaction(async (context) => {
            await flushDiffRecordsWithContext(context)
          })
          .catch((error) => {
            database.logger.error(
              `An error has been detected in the sync handler`,
              error,
            )
          })
      }

      // We can use this directly if we want to pair a flush with dispose+recreate diff trigger.
      async function flushDiffRecordsWithContext(