diff options
| author | cel <cel@f/6sQ6d2CMxRUhLpspgGIulDxDCwYD7DzFzPNr7u5AU=.ed25519> | 2017-10-17 12:31:56 -1000 |
|---|---|---|
| committer | cel <cel@f/6sQ6d2CMxRUhLpspgGIulDxDCwYD7DzFzPNr7u5AU=.ed25519> | 2017-10-17 12:36:41 -1000 |
| commit | 6d54ac255cb2f96433e88d9c2482074749bd4eea (patch) | |
| tree | 29a71a77eb1aeee2e9a735f274fc1c89b1c6e5ba /lib/render.js | |
| parent | 5299f99daca8d6d71597eb1f8b6d4115d76bfa2a (diff) | |
| download | patchfoo-6d54ac255cb2f96433e88d9c2482074749bd4eea.tar.gz patchfoo-6d54ac255cb2f96433e88d9c2482074749bd4eea.zip | |
Fix handling limit
Diffstat (limited to 'lib/render.js')
| -rw-r--r-- | lib/render.js | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/lib/render.js b/lib/render.js index a86bd92..c43ee76 100644 --- a/lib/render.js +++ b/lib/render.js @@ -314,9 +314,14 @@ Render.prototype.renderMsg = function (msg, opts, cb) { Render.prototype.renderFeeds = function (opts) { var self = this - return paramap(function (msg, cb) { - self.renderMsg(msg, opts, cb) - }, 4) + var limit = Number(opts.limit) + return pull( + paramap(function (msg, cb) { + self.renderMsg(msg, opts, cb) + }, 4), + pull.filter(Boolean), + limit && pull.take(limit) + ) } Render.prototype.gitCommitBody = function (body) { |