Commit 93cedb4dbe760934ac0138bd9f087079662060b8
Fix crash on private stream
cel committed on 10/17/2017, 6:49:25 PMParent: ef1e4683dc34451caf9669062273b4e1bef84937
Files changed
| lib/app.js | changed |
| lib/app.js | |||
|---|---|---|---|
| @@ -604,13 +604,12 @@ | |||
| 604 | 604 … | App.prototype.streamPrivate = function (opts) { | |
| 605 | 605 … | if (this.sbot.private.read) return this.filter(this.sbot.private, opts, {}) | |
| 606 | 606 … | ||
| 607 | 607 … | return pull( | |
| 608 | - this.createLogStream(u.mergeOpts(opts, {limit: null})), | ||
| 608 … | + this.createLogStream(u.mergeOpts(opts)), | ||
| 609 | 609 … | pull.filter(u.isMsgEncrypted), | |
| 610 | 610 … | this.unboxMessages(), | |
| 611 | - pull.filter(u.isMsgReadable), | ||
| 612 | - pull.take(opts.limit) | ||
| 611 … | + pull.filter(u.isMsgReadable) | ||
| 613 | 612 … | ) | |
| 614 | 613 … | } | |
| 615 | 614 … | ||
| 616 | 615 … | App.prototype.blobMentions = function (opts) { | |
Built with git-ssb-web