diff --git a/services/track-changes/app/coffee/MongoAWS.coffee b/services/track-changes/app/coffee/MongoAWS.coffee index 3fba799d22..583244bbae 100644 --- a/services/track-changes/app/coffee/MongoAWS.coffee +++ b/services/track-changes/app/coffee/MongoAWS.coffee @@ -57,7 +57,9 @@ module.exports = MongoAWS = if line.length > 2 ops.push(JSON.parse(line)) if ops.length == MongoAWS.bulkLimit + download.pause() MongoAWS.handleBulk ops.slice(0), () -> + download.resume() ops.splice(0,ops.length) .on 'end', () -> MongoAWS.handleBulk ops, callback