Function startOngoingFetch

packages/rxdb-db-collection/src/rxdb.ts:211–234

()

      let sub: Subscription
      function startOngoingFetch() {
        // Subscribe early and buffer live changes during initial load and ongoing
        sub = rxCollection.$.subscribe((ev) => {
          const cur: Row = stripRxdbFields(clone(ev.documentData as Row))
          switch (ev.operation) {
            case `INSERT`:
              queue({ type: `insert`, value: cur })
              break
            case `UPDATE`:
              queue({ type: `update`, value: cur })
              break
            case `DELETE`:
              queue({ type: `delete`, value: cur })
              break
          }
        })

        const subs = getFromMapOrCreate(
          OPEN_RXDB_SUBSCRIPTIONS,
          rxCollection,
          () => new Set(),
        )
        subs.add(sub)
      }

      async function start() {
        startOngoingFetch()