aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorcel <cel@f/6sQ6d2CMxRUhLpspgGIulDxDCwYD7DzFzPNr7u5AU=.ed25519>2017-06-13 06:37:41 -1000
committercel <cel@f/6sQ6d2CMxRUhLpspgGIulDxDCwYD7DzFzPNr7u5AU=.ed25519>2017-06-13 06:37:41 -1000
commit5f652a26f033d4de982ba32407455dd011a6f056 (patch)
tree0a2e407e1aec3e2e307aabf1d617dcefca152170
parenta01c8ba40d4da741567ee05ecb7e31c08a0534f4 (diff)
downloadpatchfoo-5f652a26f033d4de982ba32407455dd011a6f056.tar.gz
patchfoo-5f652a26f033d4de982ba32407455dd011a6f056.zip
Fix /private fallback stream
%3S0rxvdyV9+CmubFikx7pjMOTVxW9K7taqVEEE2BzvI=.sha256
-rw-r--r--lib/app.js4
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/app.js b/lib/app.js
index 433a179..873dedd 100644
--- a/lib/app.js
+++ b/lib/app.js
@@ -531,8 +531,8 @@ App.prototype.streamMentions = function (opts) {
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}),
+ return pull(
+ this.createLogStream(u.mergeOpts(opts, {limit: null})),
pull.filter(u.isMsgEncrypted),
this.unboxMessages(),
pull.filter(u.isMsgReadable),