Function queue

packages/rxdb-db-collection/src/rxdb.ts:200–208

(msg: WriteMessage)

      type WriteMessage = Parameters<typeof write>[0]
      const buffer: Array<WriteMessage> = []
      const queue = (msg: WriteMessage) => {
        if (!ready) {
          buffer.push(msg)
          return
        }
        begin()
        write(msg)
        commit()
      }

      let sub: Subscription
      function startOngoingFetch() {