diff --git a/services/track-changes/app/coffee/MongoAWS.coffee b/services/track-changes/app/coffee/MongoAWS.coffee index f2ad22bdf4..e9fb3b76d2 100644 --- a/services/track-changes/app/coffee/MongoAWS.coffee +++ b/services/track-changes/app/coffee/MongoAWS.coffee @@ -64,20 +64,21 @@ module.exports = MongoAWS = ops = [] sz = 0 - download + inputStream = download .on 'open', (obj) -> return 1 .on 'error', (err) -> callback(err) .pipe lineStream - .on 'data', (line) -> + + inputStream.on 'data', (line) -> if line.length > 2 ops.push(JSON.parse(line)) sz += line.length if ops.length >= MongoAWS.MAX_COUNT || sz >= MongoAWS.MAX_SIZE - download.pause() + inputStream.pause() MongoAWS.handleBulk ops.slice(0), sz, () -> - download.resume() + inputStream.resume() ops.splice(0,ops.length) sz = 0 .on 'end', () ->