Function start

packages/powersync-db-collection/src/powersync.ts:433–464

(afterOnChangeRegistered?: () => Promise<void>)

      // The sync function needs to be synchronous.
      async function start(afterOnChangeRegistered?: () => Promise<void>) {
        database.logger.info(
          `Sync is starting for ${viewName} into ${trackedTableName}`,
        )
        database.onChangeWithCallback(
          {
            onChange: async () => {
              await flushDiffRecords()
            },
          },
          {
            signal: abortController.signal,
            triggerImmediate: false,
            tables: [trackedTableName],
          },
        )

        await afterOnChangeRegistered?.()

        // If the abort controller was aborted while processing the request above
        if (abortController.signal.aborted) {
          await disposeTracking?.()
        } else {
          abortController.signal.addEventListener(
            `abort`,
            async () => {
              await disposeTracking?.()
            },
            { once: true },
          )
        }
      }

      // Eager mode.
      // Registers a diff trigger for the entire table.