for (auto it = first; it != last; it++, index++) {
    auto opTime = opTimeList.empty() ? repl::OpTime() : opTimeList[index];

    if (inMultiDocumentTransaction) {
        const auto atClusterTime = repl::ReadConcernArgs::get(opCtx).getArgsAtClusterTime();

        if (atClusterTime) {
            const auto shardKey =
                metadata->getShardKeyPattern().extractShardKeyFromDocThrows(it->doc);
            assertIntersectingChunkHasNotMoved(opCtx, *metadata, shardKey, *atClusterTime);
        }

        return;
    }

    auto cloner = MigrationSourceManager::getCurrentCloner(*csr);
    if (cloner) {
        cloner->onInsertOp(opCtx, it->doc, opTime);
    }
}