Function getOpenTransaction

packages/db-sqlite-persistence-core/src/persisted.ts:2212–2213

()

    sync: (params) => {
      const transactionStack: Array<OpenSyncTransaction<T, TKey>> = []
      const getOpenTransaction = () =>
        transactionStack[transactionStack.length - 1]
      let fullStartPromise: Promise<void> | null = null
      const cancelledLoadKeys = new Set<string>()
      const loadSubscriptionIds = new WeakMap<object, string>()