+4
-2
| module.exports = function More (reduce, get) { | ||
| module.exports = function More (reduce, get, state) { | ||
| var state = reduce(null) | ||
| if(!state) | ||
| state = reduce(state, null) | ||
@@ -11,2 +12,3 @@ var listeners = [] | ||
| function obv (fn, immediate) { | ||
| if(!fn) return state | ||
| listeners.push(fn) | ||
@@ -13,0 +15,0 @@ if(immediate !== false && fn(state) === true) obv.more() |
+1
-1
| { | ||
| "name": "pull-obv", | ||
| "description": "", | ||
| "version": "1.1.0", | ||
| "version": "1.2.0", | ||
| "homepage": "https://github.com/dominictarr/pull-obv", | ||
@@ -6,0 +6,0 @@ "repository": { |
+12
-0
@@ -109,2 +109,14 @@ var More = require('../') | ||
| tape('initial state', function (t) { | ||
| var obv = More(function (sum, item) { | ||
| return (sum || 0) + item | ||
| }, function (_, cb) { | ||
| cb(null, i++) | ||
| }, 10) | ||
| t.equal(obv(), 10) | ||
| t.end() | ||
| }) | ||
5686
4.48%125
9.65%