From dfa0036507dcab5dd6dadd74a9f4c491b5edebd4 Mon Sep 17 00:00:00 2001
From: Brian Gough <bjg@network-theory.co.uk>
Date: Wed, 16 Sep 2015 15:32:36 +0100
Subject: [PATCH] pause stream while writing to mongo

---
 services/track-changes/app/coffee/MongoAWS.coffee | 2 ++
 1 file changed, 2 insertions(+)

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