New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

async-co

Package Overview
Dependencies
Maintainers
2
Versions
19
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

async-co - npm Package Compare versions

Comparing version 1.2.2 to 1.3.0

16

eachLimit.js
"use strict";
const setImmediate = require('./setImmediate');
const values = require('mout/object/values');
const keys = require('mout/object/keys');
module.exports = function *(series, n, thunk, ctx) {
var n = Math.min(n || 5, series.length);
var ret = [];
var isArray = Array.isArray(series);
var iterateeSource = isArray ? series: values(series);
var iterateeKeys = keys(series)
var n = Math.min(n || 5, iterateeSource.length);
var ret = isArray ? [] : {};
var index = 0;

@@ -13,3 +21,3 @@ var cancel = false;

var next = function *() {
if (index >= series.length || cancel)
if (index >= iterateeSource.length || cancel)
return;

@@ -23,3 +31,3 @@

try { //stop replenishing after error
ret[i] = yield thunk.call(ctx || this, series[i]);
ret[ isArray ? i : iterateeKeys[i] ] = yield thunk.call(ctx || this, iterateeSource[i]);
} catch(err) {

@@ -26,0 +34,0 @@ cancel = true;

@@ -6,7 +6,8 @@ "use strict";

module.exports = function *(series, n, thunk, ctx){
var res = {};
yield eachLimit(Object.keys(series), n, function* (k){
yield thunk(series[k], k);
res[k] = yield thunk(series[k], k);
}, ctx);
return Promise.resolve(res);
};
{
"name": "async-co",
"version": "1.2.2",
"version": "1.3.0",
"description": "Control flow for co with async.js (v2) signatures",

@@ -5,0 +5,0 @@ "main": "index.js",

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc