diff --git a/src/topics/delete.js b/src/topics/delete.js index 6121868c00..135a82be00 100644 --- a/src/topics/delete.js +++ b/src/topics/delete.js @@ -116,7 +116,7 @@ module.exports = function (Topics) { function (_mainPid, next) { mainPid = _mainPid; batch.processSortedSet('tid:' + tid + ':posts', function (pids, next) { - async.eachLimit(pids, 10, function (pid, next) { + async.eachSeries(pids, function (pid, next) { posts.purge(pid, uid, next); }, next); }, { alwaysStartAt: 0 }, next);