Function createSourceUpdates

lib/persisted-model.js:1274–1292

(_diff, cb)

    }

    function createSourceUpdates(_diff, cb) {
      diff = _diff;
      diff.conflicts = diff.conflicts || [];

      if (diff && diff.deltas && diff.deltas.length) {
        debug('\tbuilding a list of updates');
        utils.uploadInChunks(
          diff.deltas,
          replicationChunkSize,
          function(smallArray, chunkCallback) {
            return sourceModel.createUpdates(smallArray, chunkCallback);
          },
          cb,
        );
      } else {
        // nothing to replicate
        done();
      }
    }

    function bulkUpdate(_updates, cb) {
      debug('\tstarting bulk update');