From 93cedb4dbe760934ac0138bd9f087079662060b8 Mon Sep 17 00:00:00 2001 From: cel Date: Tue, 17 Oct 2017 08:48:56 -1000 Subject: Fix crash on private stream --- lib/app.js | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) (limited to 'lib') diff --git a/lib/app.js b/lib/app.js index 53e6291..b0b92ee 100644 --- a/lib/app.js +++ b/lib/app.js @@ -605,11 +605,10 @@ App.prototype.streamPrivate = function (opts) { if (this.sbot.private.read) return this.filter(this.sbot.private, opts, {}) return pull( - this.createLogStream(u.mergeOpts(opts, {limit: null})), + this.createLogStream(u.mergeOpts(opts)), pull.filter(u.isMsgEncrypted), this.unboxMessages(), - pull.filter(u.isMsgReadable), - pull.take(opts.limit) + pull.filter(u.isMsgReadable) ) } -- cgit v1.2.3