1 files changed, 20 insertions, 0 deletions
diff --git a/lib/app.js b/lib/app.js
index 3ff8b81..eca2a9f 100644
--- a/lib/app.js
+++ b/lib/app.js
@@ -521,3 +521,23 @@ App.prototype.streamMentions = function (opts) {
     }}]
   }))
 }
+
+App.prototype.streamPrivate = function (opts) {
+  if (this.sbot.private.read) return this.sbot.private.read(u.mergeOpts(opts, {
+    query: [{$filter: {
+      timestamp: {
+        $gt: opts.gt,
+        $lt: opts.lt,
+      }
+    }}]
+  }))
+
+
+  return pull
+    this.createLogStream(u.mergeOpts(opts, {limit: null}),
+    pull.filter(u.isMsgEncrypted),
+    this.unboxMessages(),
+    pull.filter(u.isMsgReadable),
+    pull.take(opts.limit)
+  )
+}