Comparing version 4.5.0 to 4.5.1
@@ -6,2 +6,3 @@ const Strategy = require('@tangle/strategy') | ||
const pull = require('pull-stream') | ||
const paraMap = require('pull-paramap') | ||
@@ -220,5 +221,4 @@ const isValidSpec = require('./lib/is-valid-spec') | ||
// map rootMsg => record (and filter out the ones which were junk) | ||
pull.asyncMap( | ||
opts.read || | ||
((msg, cb) => { | ||
paraMap( | ||
opts.read || ((msg, cb) => { | ||
this.read(msg.key, (err, record) => { | ||
@@ -228,3 +228,4 @@ if (err) cb(null, false) | ||
}) | ||
}) | ||
}), | ||
opts.width || 5 | ||
), | ||
@@ -231,0 +232,0 @@ pull.filter(Boolean), |
{ | ||
"name": "ssb-crut", | ||
"version": "4.5.0", | ||
"version": "4.5.1", | ||
"description": "easy CRUT methods for secure scuttlebutt", | ||
@@ -37,2 +37,3 @@ "main": "index.js", | ||
"lodash.merge": "^4.6.2", | ||
"pull-paramap": "^1.2.2", | ||
"pull-stream": "^3.6.14", | ||
@@ -39,0 +40,0 @@ "ssb-schema-definitions": "^3.2.1" |
@@ -332,2 +332,5 @@ # ssb-crut | ||
``` | ||
- `opts.width` *Integer* | ||
- how many `read` functions to run in parallel | ||
- default: `5` | ||
@@ -334,0 +337,0 @@ --- |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
120192
3445
351
8
+ Addedpull-paramap@^1.2.2
+ Addedlooper@4.0.0(transitive)
+ Addedpull-paramap@1.2.2(transitive)