Function replicateExpectingSuccess

test/replication.test.js:1838–1854

(source, target, since)

  }

  function replicateExpectingSuccess(source, target, since) {
    if (!source) source = SourceModel;
    if (!target) target = TargetModel;

    return function doReplicate(next) {
      replicate(source, target, since, function(err, conflicts, cps) {
        if (err) return next(err);

        if (conflicts.length) {
          return next(new Error('Unexpected conflicts\n' +
            conflicts.map(JSON.stringify).join('\n')));
        }

        next();
      });
    };
  }

  function setupRaceConditionInReplication(fn) {
    const bulkUpdate = TargetModel.bulkUpdate;