Fix crash on private stream

1 files changed, 2 insertions, 3 deletions

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