You're Invited:Meet the Socket Team at RSAC and BSidesSF 2026, March 23–26.RSVP
Socket
Book a DemoSign in
Socket

transduce-async

Package Overview
Dependencies
Maintainers
1
Versions
16
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

transduce-async - npm Package Compare versions

Comparing version
0.2.1
to
0.3.0
+2
-5
package.json
{
"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",

'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]}