Initial synchronization is not interrupted

protected long copyCollection(MongoClient primary, CollectionId collectionId, long timestamp) throws InterruptedException {
    ...
    try (MongoCursor<Document> cursor = docCollection.find().iterator()) {
        while (cursor.hasNext()) {
            Document doc = cursor.next();
            ...
        }
    }
    ...
}

while (running.get() && cursor.hasNext())