From c6c23aad5e86249721b820e592392e92b60137dc Mon Sep 17 00:00:00 2001 From: barisusakli Date: Sat, 2 Aug 2014 16:48:34 -0400 Subject: [PATCH] eachLimit on move all topics --- src/socket.io/topics.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/socket.io/topics.js b/src/socket.io/topics.js index 274950d455..3370db4072 100644 --- a/src/socket.io/topics.js +++ b/src/socket.io/topics.js @@ -304,7 +304,7 @@ SocketTopics.moveAll = function(socket, data, callback) { return callback(err); } - async.each(tids, function(tid, next) { + async.eachLimit(tids, 10, function(tid, next) { threadTools.move(tid, data.cid, socket.uid, next); }, callback); });