level-sublevel
Advanced tools
Comparing version 6.6.1 to 6.6.2
{ | ||
"name": "level-sublevel", | ||
"description": "partition levelup databases", | ||
"version": "6.6.1", | ||
"version": "6.6.2", | ||
"homepage": "https://github.com/dominictarr/level-sublevel", | ||
@@ -14,4 +14,5 @@ "repository": { | ||
"ltgt": "~2.1.1", | ||
"pull-defer": "^0.2.2", | ||
"pull-level": "^2.0.3", | ||
"pull-stream": "^3.4.5", | ||
"pull-stream": "^3.6.8", | ||
"typewiselite": "~1.0.0", | ||
@@ -21,4 +22,4 @@ "xtend": "~4.0.0" | ||
"devDependencies": { | ||
"level": "^1.4.0", | ||
"level-test": "^2.0.1", | ||
"level": "^3.0.1", | ||
"level-test": "^3.0.0", | ||
"monotonic-timestamp": "0.0.8", | ||
@@ -25,0 +26,0 @@ "pull-level": "~1.1.1", |
var pull = require('pull-stream') | ||
var defer = require('pull-defer/source') | ||
// Currently this uses pull streams, | ||
@@ -9,3 +10,3 @@ // and not levelup's readstream, but in theory | ||
module.exports = function pullReadStream (options, makeData) { | ||
var stream = pull.defer() | ||
var stream = defer() | ||
@@ -12,0 +13,0 @@ stream.setIterator = function (iterator) { |
@@ -14,7 +14,8 @@ | ||
pull.count(10) | ||
.pipe(pull.map(function (i) { | ||
pull( | ||
pull.count(10), | ||
pull.map(function (i) { | ||
return {key: 'key_'+i, value: 'value_' + i} | ||
})) | ||
.pipe(pl.write(db, function (err) { | ||
}), | ||
pl.write(db, function (err) { | ||
if(err) { | ||
@@ -25,4 +26,5 @@ t.notOk(err) | ||
toPull(db.createKeyStream()) | ||
.pipe(pull.collect(function (err, ary) { | ||
pull( | ||
toPull(db.createKeyStream()), | ||
pull.collect(function (err, ary) { | ||
console.log(ary) | ||
@@ -33,4 +35,5 @@ ary.forEach(function (e) { | ||
}) | ||
toPull(db.createValueStream()) | ||
.pipe(pull.collect(function (err, ary) { | ||
pull( | ||
toPull(db.createValueStream()), | ||
pull.collect(function (err, ary) { | ||
console.log(ary) | ||
@@ -44,6 +47,9 @@ ary.forEach(function (e) { | ||
t.end() | ||
})) | ||
})) | ||
})) | ||
}) | ||
) | ||
}) | ||
) | ||
}) | ||
) | ||
}) | ||
@@ -220,1 +220,2 @@ var tape = require('tape') | ||
}) | ||
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
131701
2527
8
53
+ Addedpull-defer@^0.2.2
+ Addedpull-defer@0.2.3(transitive)
Updatedpull-stream@^3.6.8