eachLimit on move all topics

This commit is contained in:
barisusakli
2014-08-02 16:48:34 -04:00
parent 115598f382
commit c6c23aad5e

View File

@@ -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);
});