+0
-4
@@ -1,2 +0,1 @@ | ||
| module.exports = function More (reduce, get, state) { | ||
@@ -50,4 +49,1 @@ | ||
| } | ||
+2
-1
| { | ||
| "name": "pull-obv", | ||
| "description": "", | ||
| "version": "1.3.1", | ||
| "version": "1.3.2", | ||
| "homepage": "https://github.com/dominictarr/pull-obv", | ||
@@ -12,2 +12,3 @@ "repository": { | ||
| "devDependencies": { | ||
| "pull-stream": "^3.6.0", | ||
| "tape": "^4.7.0" | ||
@@ -14,0 +15,0 @@ }, |
+18
-1
| var More = require('../') | ||
| var pull = require('pull-stream') | ||
| var a = [] | ||
@@ -147,1 +147,18 @@ for (var i = 0; i < 5; i++) | ||
| tape('emits end', function (t) { | ||
| var obv = More(function (ary, item) { | ||
| return ary.concat(item) | ||
| }, pull.values([1,2]), []) | ||
| obv(function (ary) { | ||
| console.log(ary) | ||
| if(ary.ended) t.end() | ||
| }) | ||
| obv.more() | ||
| obv.more() | ||
| obv.more() | ||
| }) | ||
15642
2.02%446
3%2
100%