From 761d59f5ec9f82765150cc4adaf18ae4568a6b6d Mon Sep 17 00:00:00 2001
From: barisusakli <barisusakli@gmail.com>
Date: Tue, 2 Sep 2014 01:34:26 -0400
Subject: [PATCH] each limit on pushUnreadCount

---
 src/topics/unread.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/topics/unread.js b/src/topics/unread.js
index 41385318a4..7ad5a5e709 100644
--- a/src/topics/unread.js
+++ b/src/topics/unread.js
@@ -169,7 +169,7 @@ module.exports = function(Topics) {
 			return parseInt(value, 10) !== 0;
 		});
 
-		async.each(uids, function(uid, next) {
+		async.eachLimit(uids, 5, function(uid, next) {
 			Topics.getTotalUnread(uid, function(err, count) {
 				websockets.in('uid_' + uid).emit('event:unread.updateCount', null, count);
 				next();