transduce-async
Advanced tools
+2
-5
| { | ||
| "name": "transduce-async", | ||
| "version": "0.2.1", | ||
| "version": "0.3.0", | ||
| "description": "Async transducers with Promises, defer, delay", | ||
@@ -32,9 +32,6 @@ "main": "transduce-async.js", | ||
| "any-promise": "~0.1.0", | ||
| "transduce": "~0.5.0" | ||
| "transduce": "~0.6.0" | ||
| }, | ||
| "devDependencies": { | ||
| "tape": "~3.0.3", | ||
| "any-transduce": "~0.4.0", | ||
| "transducers-js": "~0.4.135", | ||
| "transducers.js": "~0.2.3", | ||
| "promise": "~6.0.1", | ||
@@ -41,0 +38,0 @@ "rsvp": "~3.0.16", |
+12
-7
| 'use strict' | ||
| var Prom = require('any-promise'), | ||
| comp = require('transduce/base/compose'), | ||
| arrayPush = require('transduce/util/arrayPush'), | ||
| isReduced = require('transduce/base/isReduced'), | ||
| unreduced = require('transduce/base/unreduced'), | ||
| transformer = require('transduce/transformer/transformer'), | ||
| iterator = require('transduce/iterator/iterator') | ||
| comp = require('transduce/core/compose'), | ||
| arrayPush = require('transduce/core/util').arrayPush, | ||
| isReduced = require('transduce/core/isReduced'), | ||
| unreduced = require('transduce/core/unreduced'), | ||
| transformer = require('transduce/core/transformer'), | ||
| iterable = require('transduce/core/iterable'), | ||
| protocols = require('transduce/core/protocols') | ||
@@ -72,3 +73,3 @@ var impl = module.exports = { | ||
| xf = transformer(xf) | ||
| var reduce = new Reduce(iterator(coll), init, xf) | ||
| var reduce = new Reduce(_iterator(coll), init, xf) | ||
| return reduce.iterate() | ||
@@ -142,2 +143,6 @@ } | ||
| function _iterator(coll){ | ||
| return iterable(coll)[protocols.iterator]() | ||
| } | ||
| function _iteratorValue(item){ | ||
@@ -144,0 +149,0 @@ return {done: false, value: item[0]} |
9606
0.27%6
-33.33%234
1.74%+ Added
- Removed
Updated