Function start

packages/rxdb-db-collection/src/rxdb.ts:236–248

()

      }

      async function start() {
        startOngoingFetch()
        await initialFetch()

        if (buffer.length) {
          begin()
          for (const msg of buffer) write(msg)
          commit()
          buffer.length = 0
        }

        markReady()
      }

      start()