pull-level
Advanced tools
Comparing version 1.1.1 to 1.1.2
{ | ||
"name": "pull-level", | ||
"description": "pull-stream interface to levelup", | ||
"version": "1.1.1", | ||
"version": "1.1.2", | ||
"homepage": "https://github.com/dominictarr/pull-level", | ||
@@ -12,3 +12,3 @@ "repository": { | ||
"level-fix-range": "~1.1", | ||
"pull-stream": "~2.10", | ||
"pull-stream": "~2.18", | ||
"pull-pushable": "~1.0.2", | ||
@@ -15,0 +15,0 @@ "pull-window": "~1.0.1", |
@@ -67,1 +67,11 @@ var pull = require('pull-stream') | ||
} | ||
exports.exactly = function (n) { | ||
return function (read) { | ||
return function (abort, cb) { | ||
if(0 <=--n) read(abort, cb) | ||
else cb(true) | ||
} | ||
} | ||
} | ||
@@ -27,10 +27,3 @@ | ||
}}) | ||
.pipe(function (read) { | ||
return function (abort, cb) { | ||
read(abort, function (end, data) { | ||
cb(end, data) | ||
}) | ||
} | ||
}) | ||
.pipe(pull.take(20, true)) | ||
.pipe(h.exactly(20)) | ||
.pipe(pull.collect(function (err, ary) { | ||
@@ -37,0 +30,0 @@ process.nextTick(function () { |
@@ -25,11 +25,3 @@ | ||
}}) | ||
.pipe(function (read) { //it's like pull.take(), but check BEFORE reading | ||
var n = 20 | ||
return function (a, cb) { | ||
if(n--) | ||
read(a, cb) | ||
else | ||
cb(true) | ||
} | ||
}) | ||
.pipe(h.exactly(20)) | ||
.pipe(pull.map(function (e) { | ||
@@ -36,0 +28,0 @@ return {key: e.key, value: e.value}//drop 'type' from live updates |
@@ -15,4 +15,2 @@ | ||
.pipe(pull.map(function (e) { | ||
// throw new Error('wtf') | ||
return { | ||
@@ -19,0 +17,0 @@ key: e.toString(), |
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
10976
270
+ Addedpull-stream@2.18.3(transitive)
- Removeddeep-equal@0.0.0(transitive)
- Removeddefined@0.0.0(transitive)
- Removedjsonify@0.0.1(transitive)
- Removedpull-stream@2.10.2(transitive)
- Removedtape@0.3.3(transitive)
Updatedpull-stream@~2.18