     initializing = false
 
   @_Migration: class
+    updateAll: =>
+      @_updateAll = true
+
     forward: (db, collectionName, currentSchema, newSchema, callback) =>
       db.collection collectionName, (error, collection) =>
         return callback error if error

    db = MongoInternals.defaultRemoteCollectionDriver().mongo.db
    assert db

    currentSchema = '1.0.0'
    currentSerial = 0
    currentName = initialName

      else
        newName = currentName

      migration._updateAll = false

      future = new Future()
      migration.forward db, currentName, currentSchema, newSchema, future.resolver()
      migrated = future.wait()

      updateAll = true if migrated and migration._updateAll

      if i < migrationsPending
        count = globals.Document.Migrations.update
