diff options
| author | cel <cel@f/6sQ6d2CMxRUhLpspgGIulDxDCwYD7DzFzPNr7u5AU=.ed25519> | 2017-03-16 10:49:03 -0400 |
|---|---|---|
| committer | cel <cel@f/6sQ6d2CMxRUhLpspgGIulDxDCwYD7DzFzPNr7u5AU=.ed25519> | 2017-03-16 10:49:03 -0400 |
| commit | 69d1c3c6fb9831d958dd04ef99052de75de43237 (patch) | |
| tree | 7042673e3ce57495ea4ac3673184a7755eb1886b /lib/serve.js | |
| parent | f2413e147654886107094029c3ac41342bfbcdcb (diff) | |
| download | patchfoo-69d1c3c6fb9831d958dd04ef99052de75de43237.tar.gz patchfoo-69d1c3c6fb9831d958dd04ef99052de75de43237.zip | |
increase unbox parallelism
Diffstat (limited to 'lib/serve.js')
| -rw-r--r-- | lib/serve.js | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/serve.js b/lib/serve.js index 89f7f09..f5101e1 100644 --- a/lib/serve.js +++ b/lib/serve.js @@ -265,7 +265,7 @@ Serve.prototype.private = function (ext) { pull( this.app.createLogStream(opts), pull.filter(isMsgEncrypted), - paramap(this.app.unboxMsg, 4), + paramap(this.app.unboxMsg, 16), pull.filter(isMsgReadable), pull.take(limit), this.renderThreadPaginated(opts, null, q), @@ -421,7 +421,7 @@ Serve.prototype.id = function (id, ext) { pull( cat([pull.once(rootMsg), self.app.sbot.links({dest: id, values: true})]), pull.unique('key'), - paramap(self.app.unboxMsg, 4), + paramap(self.app.unboxMsg, 16), pull.collect(function (err, links) { if (err) return self.respond(500, err.stack || err) pull( |